更新时间:2022-12-14 GMT+08:00
Network communication (via Netty)
配置场景
Flink运行Job时,Task之间的数据传输和反压检测都依赖Netty,某些环境下可能需要对Netty参数进行配置。
配置描述
对于高级调优,可调整以下Netty配置项,默认配置已可满足大规模集群并发高吞吐量的任务,参数详情可参考Netty官网:http://netty.io/。
参数 |
描述 |
默认值 |
是否必选配置 |
---|---|---|---|
taskmanager.network.netty.num-arenas |
Netty内存块数。 |
1 |
否 |
taskmanager.network.netty.server.numThreads |
Netty服务器线程的数量。 |
1 |
否 |
taskmanager.network.netty.client.numThreads |
Netty客户端线程数。 |
1 |
否 |
taskmanager.network.netty.client.connectTimeoutSec |
Netty客户端连接超时。单位:s。 |
120 |
否 |
taskmanager.network.netty.sendReceiveBufferSize |
Netty发送和接收缓冲区大小。 默认为系统缓冲区大小(cat / proc / sys / net / ipv4 / tcp_ [rw] mem),在现代Linux中为4MB。单位:bytes。 |
4096 |
否 |
taskmanager.network.netty.transport |
Netty传输类型,“nio”或“epoll”。 |
nio |
否 |
父主题: 配置管理Flink