[FLINK-2529] [runtime] Remove some unused code in Execution

This closes #1022

[FLINK-2529] [runtime] Remove some unused code in Execution
This closes #1022
8a59f87b · HuangWHWHW · Stephan Ewen · 240e8895 · 8a59f87b
隐藏空白更改
内联并排

Showing with 0 addition and 2 deletion

flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ...va/org/apache/flink/runtime/executiongraph/Execution.java +0 -2

未找到文件。
--- 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());