davidradl commented on code in PR #27446:
URL: https://github.com/apache/flink/pull/27446#discussion_r2712376097
##########
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##########
@@ -325,6 +325,28 @@ public enum CompressionCodec {
code(NETWORK_REQUEST_BACKOFF_MAX.key()))
.build());
+ /** Whether to improve the rebalance to dynamic rebalance. */
+ @Documentation.Section(Documentation.Sections.ALL_TASK_MANAGER_NETWORK)
+ public static final ConfigOption<Boolean> ADAPTIVE_PARTITIONER_ENABLE =
+ key("taskmanager.network.adaptive-partitioner.enabled")
+ .booleanType()
+ .defaultValue(false)
+ .withDescription(
+ "Whether to enabled adaptive partitioner feature
for rescale and rebalance partitioners based on the loading of the downstream
tasks.");
+
+ /** How many channels to traverse at most when looking for an idle
channel. */
+ @Documentation.Section(Documentation.Sections.ALL_TASK_MANAGER_NETWORK)
+ public static final ConfigOption<Integer>
ADAPTIVE_PARTITIONER_MAX_TRAVERSE_SIZE =
+ key("taskmanager.network.adaptive-partitioner.max-traverse-size")
+ .intType()
+ .defaultValue(4)
+ .withDescription(
+ Description.builder()
+ .text(
+ "How many channels to traverse at
most when looking for the idlest channel for rescale and rebalance partitioners
when enabled %s.",
Review Comment:
nit: when enabled %s.", -> when %s is enabled .",
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
