pnowojski commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1024243886
The case in the 3rd chart is not working in your version. If `Complete` action happens at the very very end (around `to here` arrow), there is no guarantee that it will "complete the newly created future". As you haven't established happens-before relationship between `Reset` and `Complete` actions, `Complete` might see an outdated, already completed, version of the `availableFuture`, failing to wake up the task thread. Could check my other questions? > Can you post what JDK version you are using? How are you executing this test? Are you using some extra steps, maybe manually changing some configuration/environmental variables? > > Also shouldn't the test disable checkpointing? Otherwise I think every CheckpointBarrier would switch every input to available, releasing all of the accumulated CompletableFuture's. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
