参考:点击
二、参数设置说明 举例一TaskManager 数量=3、Jobmanager 数量=1
算子并行度=2、每个 TM 的 solt 数量=1
TaskManager 的内存和cpu 如下:2GB、1core
JobManager 的内存和cpu 如下: 1GB、1core
那么总的资源消耗是
内存总量= 32+1 = 7GB
cpu 总量= 31 + 1 =4core
每个 solt 分到的内存资源 = 2/1=2GB
每个 solt 分到的cpu 资源 = 1/1=1core

计算 TaskManager 数量: 50/4 = 13 , 13个TM一共可以提供13*4=52 个 slot。最大并发是50,只占了 50 slot,还剩下52-50=2 空闲,所以建议设置 算子并行度 为 52,避免浪费设置 TaskManager 内存: 2G/4=500MB 左右,可适当调大些,具体要看监控,避免 OOM设置 Solt 的数量: 不能超过单台设备 cpu 的 core 数量,一般设置 2。设置 JobManager 内存: 主要是管理 TaskManger ,所以 TaskManager 不多的情况下,只需要 1GB 内存就行