wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1024815295
If the `Complete` indicates the input future completion. (Thats a little different in my graph. In the graph it refers to the line the calls the `complete` on the result future). when anyOf is being executed, and the input future is not ready at that time. It complete some time after that. I couldn't see how can the callback get the obsolete object. Dirty inconsistence between CPU cache cannot last that long. The callback will see the correct object. Any way, I already change the `availableFuture` to `volatile`. Which make this GONE. -- 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
