zjureel commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r974073384
##########
flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java:
##########
@@ -451,6 +451,14 @@ public class NettyShuffleEnvironmentOptions {
.withDescription(
"Maximum backoff in milliseconds for partition
requests of input channels.");
+ /** The timeout for partition request notifier. */
+ @Documentation.Section(Documentation.Sections.ALL_TASK_MANAGER_NETWORK)
+ public static final ConfigOption<Long> NETWORK_REQUEST_NOTIFY_TIMEOUT =
+ key("taskmanager.network.partition-request-notify-timeout-ms")
+ .longType()
+ .defaultValue(10000L)
+ .withDescription("Timeout in milliseconds for partition
request notifier in result partition manager.");
+
Review Comment:
It's a so good point! I have updated the back off in RemoteInputChannel,
thanks
--
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]
