[FLINK-11544] [rest] Add Nullable annotation to PackagedProgramUtils

silenceland · Feb 14, 2019 · 70f1362 · 70f1362
1 parent 4de10bb
commit 70f1362
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java b/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java
@@ -31,6 +31,8 @@
 import org.apache.flink.optimizer.plantranslate.JobGraphGenerator;
 import org.apache.flink.runtime.jobgraph.JobGraph;
 
+import javax.annotation.Nullable;
+
 import java.net.URISyntaxException;
 import java.net.URL;
 
@@ -54,7 +56,7 @@ public static JobGraph createJobGraph(
 			PackagedProgram packagedProgram,
 			Configuration configuration,
 			int defaultParallelism,
-			JobID jobID) throws ProgramInvocationException {
+			@Nullable JobID jobID) throws ProgramInvocationException {
 		Thread.currentThread().setContextClassLoader(packagedProgram.getUserCodeClassLoader());
 		final Optimizer optimizer = new Optimizer(new DataStatistics(), new DefaultCostEstimator(), configuration);
 		final FlinkPlan flinkPlan;