Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5771
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177751742
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177746665
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177730580
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177375838
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177343764
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177339622
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5771
[FLINK-9094] [tests] Harden AccumulatorLiveITCase
## What is the purpose of the change
The problem was that we did not wait for the proper shut down of the job
before
resetting
