[hotfix][streaming] correct return type of execute(..) method

apache · Sep 28, 2015 · 0f17755 · 0f17755
1 parent dd51c97
commit 0f17755
Showing 1 changed file with 5 additions and 8 deletions.
diff --git a/.../src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/.../src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -23,7 +23,6 @@
 import org.apache.flink.api.common.ExecutionConfig;
 import org.apache.flink.api.common.InvalidProgramException;
 import org.apache.flink.api.common.JobExecutionResult;
-import org.apache.flink.api.common.JobSubmissionResult;
 import org.apache.flink.api.common.functions.InvalidTypesException;
 import org.apache.flink.api.common.io.FileInputFormat;
 import org.apache.flink.api.common.io.InputFormat;
@@ -1303,9 +1302,8 @@ public static StreamExecutionEnvironment createRemoteEnvironment(String host, in
 	 * The program execution will be logged and displayed with a generated
 	 * default name.
 	 *
-	 * @return The result of the job execution, containing elapsed time and
-	 * accumulators.
-	 * @throws Exception
+	 * @return The result of the job execution, containing elapsed time and accumulators.
+	 * @throws Exception which occurs during job execution.
 	 */
 	public abstract JobExecutionResult execute() throws Exception;
 
@@ -1318,11 +1316,10 @@ public static StreamExecutionEnvironment createRemoteEnvironment(String host, in
 	 *
 	 * @param jobName
 	 * 		Desired name of the job
-	 * @return The result of the job execution: Either JobSubmissionResult or JobExecutionResult;
-	 * The latter contains elapsed time and accumulators.
-	 * @throws Exception
+	 * @return The result of the job execution, containing elapsed time and accumulators.
+	 * @throws Exception which occurs during job execution.
 	 */
-	public abstract JobSubmissionResult execute(String jobName) throws Exception;
+	public abstract JobExecutionResult execute(String jobName) throws Exception;
 
 	/**
 	 * Getter of the {@link org.apache.flink.streaming.api.graph.StreamGraph} of the streaming job.