flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject flink git commit: [hotfix][streaming] correct return type of execute(..) method
Date Mon, 28 Sep 2015 21:25:40 GMT
Repository: flink
Updated Branches:
  refs/heads/master dd51c9774 -> 0f1775576


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


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0f177557
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0f177557
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0f177557

Branch: refs/heads/master
Commit: 0f17755766f2c4ada37bb196981c7dc01016f73c
Parents: dd51c97
Author: Maximilian Michels <mxm@apache.org>
Authored: Mon Sep 28 20:07:18 2015 +0200
Committer: Maximilian Michels <mxm@apache.org>
Committed: Mon Sep 28 21:19:38 2015 +0200

----------------------------------------------------------------------
 .../api/environment/StreamExecutionEnvironment.java    | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/0f177557/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
index 621d52a..2a31390 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -23,7 +23,6 @@ import com.google.common.base.Preconditions;
 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 abstract class StreamExecutionEnvironment {
 	 * 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 abstract class StreamExecutionEnvironment {
 	 *
 	 * @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.


Mime
View raw message