subject:"\[GitHub\] \[flink\] huwh commented on a diff in pull request #22098\: \[FLINK\-31144\]\[coordination\] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the corre"

[GitHub] [flink] huwh commented on a diff in pull request #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the corre

2023-03-07 Thread via GitHub

huwh commented on code in PR #22098: URL: https://github.com/apache/flink/pull/22098#discussion_r1128938614 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java: ## @@ -95,8 +95,7 @@ private CompletableFuture>

[GitHub] [flink] huwh commented on a diff in pull request #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the corre

2023-03-05 Thread via GitHub

huwh commented on code in PR #22098: URL: https://github.com/apache/flink/pull/22098#discussion_r1125845041 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java: ## @@ -35,7 +35,7 @@ /** * Default implementation of

[GitHub] [flink] huwh commented on a diff in pull request #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the corre

[GitHub] [flink] huwh commented on a diff in pull request #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the corre

2 matches

Site Navigation

Mail list logo

Footer information