wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1024448903
I can make test for the scenario you described which my fix will fail. Just manually create a gap, resolve the reference first, then a long sleep, then try to complete. During the long sleep the other thread have the opptunity to finish the reset and register steps. I'm quite sure it will work just fine. But, still I can make this test. -- 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