aljoscha opened a new pull request #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability URL: https://github.com/apache/flink/pull/8053 Before, the was a race condition between the termination future in TaskManagerRunner completing and the asynchronous shutdown part here: https://github.com/apache/flink/blob/70107c4647ecac3df9b2b8c7920e7cb99ad550f1/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java#L258 The test would go out of the block that was waiting on the future but the shutdown code that is executed after the future completes is executed asynchronously, so is not guaranteed to have run at that point. This also refactors the code a bit to make it more obvious what is happening and removes the SecurityManagerContext because it was obscuring the problem. ## Verifying this change This change is already covered by existing tests, such as *(please describe tests)*.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
