dmvk commented on a change in pull request #18332:
URL: https://github.com/apache/flink/pull/18332#discussion_r783078659
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
##########
@@ -1175,6 +1185,31 @@ private void terminateMiniClusterServices() throws
Exception {
}
}
+ /**
+ * Prevent multiple submission of the same JobGraph that has been mutated
in between
Review comment:
Yes it should be as the job graph needs to be send over the network so
it's effectively cloned, any mutations to the JobGraph on the client side
wouldn't affect the instance used by Dispatcher.
As I've already suggested, the other option would be simply cloning the job
graph here.
@zentol do you have any thoughts on this one?
--
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]
