dawidwys commented on a change in pull request #18332: URL: https://github.com/apache/flink/pull/18332#discussion_r784667192
########## 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, I agree with the analysis. However, I'd rather go with the serialization approach you suggested. Otherwise we are imposing a contract on the MiniCluster that is different from regular clusters. At least that's my take. WDYT? -- 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