通过k8s-session部署的flink 集群,三个节点,job提交上去后为什么只占用一个task 
manager的节点。目前这样,导致数据倾斜,每次checkpoint 都会失败






 

回复