TanYuxin-tyx commented on code in PR #21620:
URL: https://github.com/apache/flink/pull/21620#discussion_r1070890224
##########
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##########
@@ -225,6 +225,35 @@ public class NettyShuffleEnvironmentOptions {
+ " help relieve back-pressure caused by
unbalanced data distribution among the subpartitions. This value should be"
+ " increased in case of higher round trip
times between nodes and/or larger number of machines in the cluster.");
+ /**
+ * Maximum number of network buffers to use for each outgoing/incoming
gate (result
+ * partition/input gate), which contains all exclusive network buffers for
all subpartitions and
+ * all floating buffers for the gate. The exclusive network buffers for
one channel is
+ * configured by {@link #NETWORK_BUFFERS_PER_CHANNEL} and the floating
buffers for one gate is
+ * configured by {@link #NETWORK_EXTRA_BUFFERS_PER_GATE}.
+ */
+ @Experimental
+ @Documentation.Section(Documentation.Sections.ALL_TASK_MANAGER_NETWORK)
+ public static final ConfigOption<Integer>
NETWORK_READ_MAX_REQUIRED_BUFFERS_PER_GATE_MAX =
Review Comment:
Fixed.
--
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]
