更新时间:2022-12-14 GMT+08:00

Network communication (via Netty)

配置场景

Flink运行Job时,Task之间的数据传输和反压检测都依赖Netty,某些环境下可能需要对Netty参数进行配置。

配置描述

对于高级调优,可调整以下Netty配置项,默认配置已可满足大规模集群并发高吞吐量的任务,参数详情可参考Netty官网:http://netty.io/

表1 参数说明

参数

描述

默认值

是否必选配置

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