[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r808923933 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +327,87 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r807972099 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/TestAccessExecution.java ## @@ -0,0 +1,111 @@ +/* + * Licensed

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r807914546 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateTransitions.java ## @@ -72,6 +75,21 @@ void goToExecuting(

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r807890572 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/BoundedFIFOQueue.java ## @@ -56,14 +57,26 @@ public BoundedFIFOQueue(int maxSize) {

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r807877208 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateTransitions.java ## @@ -72,6 +75,21 @@ void goToExecuting(

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r806187996 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +327,73 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r806187996 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +327,73 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805652431 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +331,88 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805618265 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +331,88 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805618265 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +331,88 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805607024 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +331,88 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805604192 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +331,88 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805592620 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -306,22 +331,88 @@ void deliverOper

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805205602 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java ## @@ -969,10 +979,203 @@ public void testH

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805206533 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805205858 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805205602 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java ## @@ -969,10 +979,203 @@ public void testH

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r804438339 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r804434972 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/failure/Failure.java ## @@ -0,0 +1,72 @@ +/* + * Licensed to the Apach

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r804433236 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/failure/LocalFailure.java ## @@ -0,0 +1,77 @@ +/* + * Licensed to the

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803829190 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -1576,4 +1576,15 @@ public ExecutionDeplo

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803828457 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -1576,4 +1576,15 @@ public ExecutionDeplo

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803794145 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803790449 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803786630 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803770073 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StopWithSavepoint.java ## @@ -134,30 +143,53 @@ public JobStatus getJo

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803761345 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803659647 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get