huwh opened a new pull request, #22836: URL: https://github.com/apache/flink/pull/22836
## What is the purpose of the change Add keepalive options to NettyClient. refer to: https://issues.apache.org/jira/browse/FLINK-32191 ## Brief change log - *Add tcp keepalive related options to Netty client..* - *For transport type of Epoll, set these configuration to NettyClient#bootstrap directly* - *For transport type of Nio, set these configuration through reflection. Because some old versions of Java don't support certain features.* ## Verifying this change This change added tests and can be verified as follows: - *Added test that validates that NettyClient could set these configuration in NIO and Epoll* - *Verified the change by manually dropping the TCP Ack Package through iptables.* - JDK 11 with NIO, TCP Keepalive is in effect. - JDK 11 with Epoll, TCP Keepalive is in effect. - JDK8u131 with Epoll, TCP Keepalive is in effect. - JDK8u322 with NIO, TCP Keepalive is in effect. - JDK8u131 with NIO, TCP Keepalive does not work ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (no) - The runtime per-record code paths (performance sensitive): (no) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no) - The S3 file system connector: (no) ## Documentation - Does this pull request introduce a new feature? (no) -- 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]
