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(
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(
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 @@
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
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(
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
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
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
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