[GitHub] [flink] dmvk commented on a change in pull request #18238: WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

dmvk commented on a change in pull request #18238: URL: https://github.com/apache/flink/pull/18238#discussion_r776611441 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java ## @@ -0,0 +1,301 @@ +/* + *

[GitHub] [flink] dmvk commented on a change in pull request #18238: WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

dmvk commented on a change in pull request #18238: URL: https://github.com/apache/flink/pull/18238#discussion_r776613842 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java ## @@ -203,6 +204,8 @@ private final Sch

[GitHub] [flink] dmvk commented on a change in pull request #18238: WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

dmvk commented on a change in pull request #18238: URL: https://github.com/apache/flink/pull/18238#discussion_r776614525 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java ## @@ -103,60 +112,53 @@ publi

[GitHub] [flink] dmvk commented on a change in pull request #18238: WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

dmvk commented on a change in pull request #18238: URL: https://github.com/apache/flink/pull/18238#discussion_r776614745 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java ## @@ -0,0 +1,301 @@ +/* + *

[GitHub] [flink] dmvk commented on a change in pull request #18238: WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

dmvk commented on a change in pull request #18238: URL: https://github.com/apache/flink/pull/18238#discussion_r776615258 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java ## @@ -382,6 +382,21 @@ public static int runTaskMana