rkhachatryan opened a new pull request, #28849: URL: https://github.com/apache/flink/pull/28849
``` testCancelOtherScheduledCurrentExecutionsWhenAnyExecutionFinished starts scheduling asynchronously (createSchedulerAndStartScheduling(false)) and polls for the execution vertex via waitUntilIgnoringExceptions. That poll loop only guards against exceptions thrown while fetching the vertex; it discards the fetched value and unconditionally returns true, then the vertex is fetched a second, independent time right after the loop. Between these two fetches, the scheduler thread can still be populating the execution graph, so the second fetch occasionally observes a null element instead of throwing, causing: NullPointerException: Cannot invoke "ExecutionVertex.getCurrentExecutionAttempt()" because "ev" is null Capture the vertex from the successful poll iteration itself, and make the poll condition require a non-null result, instead of re-querying the scheduler afterwards. ``` -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
