[GitHub] [flink] zhuzhurk commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
zhuzhurk commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r786479084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/RegionPartitionGroupReleaseStrategy.java #

[GitHub] [flink] zhuzhurk commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-17 Thread GitBox
zhuzhurk commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r786442228 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -159,50 +162,79 @@ public stati

[GitHub] [flink] zhuzhurk commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-17 Thread GitBox
zhuzhurk commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r785714256 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultOperatorCoordinatorHandler.java ## @@ -62,11 +62,17 @@ public Defaul

[GitHub] [flink] zhuzhurk commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-16 Thread GitBox
zhuzhurk commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r785638944 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingResultPartition.java ## @@ -48,11 +49,11 @@ ResultP