azagrebin opened a new pull request #13908: URL: https://github.com/apache/flink/pull/13908
The state updates for `ExecutionStateUpdateListener` in `ExecutionGraph#notifyExecutionChange` are not done at the moment because `ExecutionGraph#notifyExecutionChange` is currently enabled only for legacy scheduling. The state update handling is supposed to be done only in `SchedulerNG` (`DefaultScheduler`), not in legacy code of `ExecutionGraph`. However, this generally requires more refactoring for execution deployment tracking and reconciliation. Hence, this PR just enables ExecutionStateUpdateListener state updates in `ExecutionGraph#notifyExecutionChange` for `SchedulerNG` as a quick fix, before we refactor the execution deployment tracking and reconciliation. `JobMasterExecutionDeploymentReconciliationTest#testExecutionDeploymentReconciliation` is also extended with the check that `ExecutionStateUpdateListener` is called and the execution deployment tracking is stopped. The PR also refactors tests in `JobMasterExecutionDeploymentReconciliationTest` and introduces `TestingExecutionDeploymentTrackerWrapper` to facilitate `ExecutionDeploymentTracker` call checks. ---------------------------------------------------------------- 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]
