flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [FLINK-2483] [runtime] Add default branch of switch(scheduleMode) in scheduleForExecution function
Date Mon, 10 Aug 2015 19:33:29 GMT
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 <869218239@qq.com>
Authored: Tue Aug 4 20:12:46 2015 +0800
Committer: Stephan Ewen <sewen@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 {


Mime
View raw message