You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/08/10 21:33:29 UTC
flink git commit: [FLINK-2483] [runtime] Add default branch of
switch(scheduleMode) in scheduleForExecution function
Repository: flink
Updated Branches:
refs/heads/master ceb5c5e2f -> b19e5e3bb
[FLINK-2483] [runtime] Add default branch of switch(scheduleMode) in scheduleForExecution function
This closes #984
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b19e5e3b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b19e5e3b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b19e5e3b
Branch: refs/heads/master
Commit: b19e5e3bb39fad27962415ae432d616aa98fc298
Parents: ceb5c5e
Author: ffbin <86...@qq.com>
Authored: Tue Aug 4 20:12:46 2015 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Aug 10 20:46:08 2015 +0200
----------------------------------------------------------------------
.../org/apache/flink/runtime/executiongraph/ExecutionGraph.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b19e5e3b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
old mode 100644
new mode 100755
index be92bd4..b52a4e8
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
@@ -666,6 +666,8 @@ public class ExecutionGraph implements Serializable {
case BACKTRACKING:
// go back from vertices that need computation to the ones we need to run
throw new JobException("BACKTRACKING is currently not supported as schedule mode.");
+ default:
+ throw new JobException("Schedule mode is invalid.");
}
}
else {