zentol opened a new pull request #12815: URL: https://github.com/apache/flink/pull/12815
With this PR the `JobMaster` can detect and reconcile deployments that are missing or unknown. The `TaskExecutor` is periodically informing the `JobMaster` about the set of deployed executions, submitted with the heartbeat. The `Scheduler` tracks the set of expected deployments with a new `ExecutionDeploymentTracker` component. The tracker is updated of deployed/terminated deployments by 2 new listeners in the `ExecutionGraph`. The `JobMaster` reconciles deployments with a new `ExecutionDeploymentReconciler` component. If the `TaskExecutor` is hosting an unexpected execution, then that execution will be canceled. If the `TaskExecutor` is unexpectedly not hosting an execution, then the execution is failed in the `ExecutionGraph.` ---------------------------------------------------------------- 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]
