You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/03/06 09:20:16 UTC
[flink] 01/02: [hotfix][runtime] Remove unused local variable in
ExecutionGraph
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9ac14a6048982d5bdd19379114ef109483c2abce
Author: Gary Yao <ga...@apache.org>
AuthorDate: Fri Mar 1 18:06:38 2019 +0100
[hotfix][runtime] Remove unused local variable in ExecutionGraph
---
.../java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java | 1 -
1 file changed, 1 deletion(-)
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
index e64b2b9..ff7e123 100644
--- 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
@@ -1825,7 +1825,6 @@ public class ExecutionGraph implements AccessExecutionGraph {
// see what this means for us. currently, the first FAILED state means -> FAILED
if (newExecutionState == ExecutionState.FAILED) {
final Throwable ex = error != null ? error : new FlinkException("Unknown Error (missing cause)");
- long timestamp = execution.getStateTimestamp(ExecutionState.FAILED);
// by filtering out late failure calls, we can save some work in
// avoiding redundant local failover