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/18 16:38:20 UTC
[6/7] flink git commit: [FLINK-2529] [runtime] Remove some unused
code in Execution
[FLINK-2529] [runtime] Remove some unused code in Execution
This closes #1022
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8a59f87b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8a59f87b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8a59f87b
Branch: refs/heads/master
Commit: 8a59f87bd4b3ec15d9bafae8e7de6d8a55e070b1
Parents: 240e889
Author: HuangWHWHW <40...@qq.com>
Authored: Sun Aug 16 11:56:18 2015 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Aug 18 16:37:41 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/executiongraph/Execution.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8a59f87b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
index aa0f981..64c4d47 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
@@ -497,8 +497,6 @@ public class Execution implements Serializable {
@Override
public Boolean call() throws Exception {
try {
- final ExecutionGraph consumerGraph = consumerVertex.getExecutionGraph();
-
consumerVertex.scheduleForExecution(
consumerVertex.getExecutionGraph().getScheduler(),
consumerVertex.getExecutionGraph().isQueuedSchedulingAllowed());