Repository: flink Updated Branches: refs/heads/release-1.2 33659f524 -> 664c49df7
[FLINK-5623] [runtime] Fix TempBarrier dam has been closed Properly reset the "pipeline breaker" upon closing. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/664c49df Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/664c49df Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/664c49df Branch: refs/heads/release-1.2 Commit: 664c49df7e76b61fbf84cf1b416dff5d0cfdd2ac Parents: 33659f5 Author: Greg Hogan <[email protected]> Authored: Thu Apr 20 08:46:01 2017 -0400 Committer: Stephan Ewen <[email protected]> Committed: Fri Apr 21 14:34:20 2017 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/runtime/operators/BatchTask.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/664c49df/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java index f748079..87b0a76 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java @@ -884,6 +884,7 @@ public class BatchTask<S extends Function, OT> extends AbstractInvokable impleme // close the async barrier if there is one if (this.tempBarriers[i] != null) { this.tempBarriers[i].close(); + this.tempBarriers[i] = null; } // recreate the local strategy
