[GitHub] [flink] zentol commented on a change in pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

zentol commented on a change in pull request #18194: URL: https://github.com/apache/flink/pull/18194#discussion_r786552952 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -195,6 +195,8 @@ public Dispatcher( this.disp

[GitHub] [flink] zentol commented on a change in pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

zentol commented on a change in pull request #18194: URL: https://github.com/apache/flink/pull/18194#discussion_r786551265 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -195,6 +195,8 @@ public Dispatcher( this.disp

[GitHub] [flink] zentol commented on a change in pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

zentol commented on a change in pull request #18194: URL: https://github.com/apache/flink/pull/18194#discussion_r786254780 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java ## @@ -1045,6 +1048,27 @@ public void testJobDataAreCle

[GitHub] [flink] zentol commented on a change in pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

zentol commented on a change in pull request #18194: URL: https://github.com/apache/flink/pull/18194#discussion_r785434264 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -195,6 +195,8 @@ public Dispatcher( this.disp