flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [6/7] flink git commit: [FLINK-2529] [runtime] Remove some unused code in Execution
Date Tue, 18 Aug 2015 14:38:20 GMT
[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 <404823056@qq.com>
Authored: Sun Aug 16 11:56:18 2015 +0800
Committer: Stephan Ewen <sewen@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());


Mime
View raw message