flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tillrohrmann <...@git.apache.org>
Subject [GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery
Date Thu, 01 Feb 2018 10:50:38 GMT
Github user tillrohrmann commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5239#discussion_r165318246
  
    --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTerminationTest.java
---
    @@ -227,21 +229,13 @@ protected void cleanup() throws Exception {
     			// has been stopped
     			CLEANUP_LATCH.trigger();
     
    -			// wait until handle async exception has been called to proceed with the termination
of the
    -			// StreamTask
    -			HANDLE_ASYNC_EXCEPTION_LATCH.await();
    --- End diff --
    
    This handle should be deleted since it is no longer needed.


---

Mime
View raw message