swapna267 commented on code in PR #28002:
URL: https://github.com/apache/flink/pull/28002#discussion_r3144055187
##########
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java:
##########
@@ -1337,6 +1342,37 @@ private void persistAndRunJob(ExecutionPlan
executionPlan) throws Exception {
createJobMasterRunner(executionPlan),
ExecutionType.SUBMISSION,
executionPlan.getApplicationId().orElse(null));
+ notifyJobCreated(executionPlan);
Review Comment:
We could still see a race condition here, as runJob and notifyJobCreated can
run in parallel in separate threads.
There is a chance that JobExecutionStatusEvent is fired before
JobCreatedEvent.
One way to avoid could be to run this before runJob is submitted.
--
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]
