从 RocketMQ 中消费数据做处理。 代码中最大的并行度为 8， 提交任务时指定 -ys 4 ，会自动分配 2 个 container 作为 taskMgr 运行一段时间后以 savepoint 方式停止。 再从 savepoint 恢复，此时指定 -ys 2 ， 会分配 4 个container 作为 taskMgr ， 但任务提交后程序不从 RocketMQ 消费数据了，消费 TPS 一直是 0，这是什么原因呢？
谢谢， 王磊 wangl...@geekplus.com.cn
- 从 state 中恢复数据，更改 yarn container 个数会有影响吗 wangl...@geekplus.com.cn
