LoveHeat commented on PR #22808: URL: https://github.com/apache/flink/pull/22808#issuecomment-1598030633
The first path is(just simple call stack not full): [create JobMaster for each recovered job, and will init a scheduler object in jobmaster construct function](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java#L354) ---> [init a executionGraph in schedulerBase construct function](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java#L210) ---> [init JobVertices when attach job vertex to jobgraph](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java#L825) ---> [finally create OperatorCoordinator when init executionJobVertex](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java#L222) the first sourceCoordinator will not be started after created, all operatorCoordinator will be started before startScheduler, see [start all opeatorCoordinator](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java#L617) The second path is: [after init ExecutionGraph will recover job from checkpoint](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java#L194) ---> [restore sourceCoordinator](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L1753) ---> [call resetToCheckpoint() to reset SourceCoordinator](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/RecreateOnResetOperatorCoordinator.java#L120), but because the first is not started, so scheduled period task will not stopped -- 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
