[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-25 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r791168425 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java ## @@ -55,14 +57,16 @@ public MiniDispatcher(

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-24 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r791168425 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java ## @@ -55,14 +57,16 @@ public MiniDispatcher(

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-19 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r787614773 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcessTest.java ## @@ -130,28 +146,56 @@

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-17 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r785912691 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -870,6 +871,7 @@ private void

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-11 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r782116207 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java ## @@ -63,6 +63,7 @@ public MiniDispatcher(

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-10 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r781109586 ## File path: flink-core/src/main/java/org/apache/flink/util/function/QuintFunction.java ## @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-08 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r780210722 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ApplicationStatus.java ## @@ -59,20 +72,25 @@ public int

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-07 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r780341370 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java ## @@ -92,34 +99,61 @@ private

[GitHub] [flink] dmvk commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-07 Thread GitBox
dmvk commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r780210722 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ApplicationStatus.java ## @@ -59,20 +72,25 @@ public int