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 <[email protected]> Authored: Mon Sep 28 20:07:18 2015 +0200 Committer: Maximilian Michels <[email protected]> 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.
