rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1122893111
##########
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java:
##########
@@ -143,7 +143,7 @@ private void handleExecutionGraphCreation(
} else {
logger.debug(
"Failed to reserve and assign the required slots.
Waiting for new resources.");
- context.goToWaitingForResources();
+ context.goToWaitingForResources(null);
Review Comment:
Good point, thanks!
No, it's not correct. But the fix isn't complex - I pushed
c4aaddb464f39d454d6d4f362cf4a0cf5b4973af to add the `previousExecutionGraph` to
`CreatingExecutionGraph` and then pass it to `WaitingForResources`.
--
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
