建议看下集群剩余的内存情况，看是不是 140 个 TAskManager 内存不够了
--
Sent from: http://apache-flink.147419.n8.nabble.com/
hi
flink 1 slot != 1 core
可以看下 yarn.containers.vcores 这个参数设置为多少。
如果该值为1，tm slot为2，那么每启动一个tm容器就会占用1core，但是每个tm 会有两个slot，反之，如果该值为1，每个tm slot
也为1，就会需要max parallelism core 数量。
在2021年3月11日 14:34，lzwang 写道：
您好：
任务的拓扑图如下，parallelism的设置是140，但是中间有个操作的并行度设置成了50。
集群剩余的slot总数是195。
您好：
任务的拓扑图如下，parallelism的设置是140，但是中间有个操作的并行度设置成了50。
集群剩余的slot总数是195。
如果将每个tm的slot数设置为2，任务能够正常启动，并且分配了70个tm和140个slot，符合预期。
可如果将每个tm的slot数设置为1，便只分配了115个slot。任务会卡在creating状态，并且几分钟后，会抛出异常，“Could not
allocate all requires slots within timeout of 30 ms. Slots required: 470,
slots
