- 1.概述
- M.扩展
1.概述
一个flink程序,如下,但是总共100多个task,然后只有一个没有数据。
第一怀疑是不是keyBy问题,上述看错了,然后以为有keyBy 然后参考文章:【Flink】Flink状态的缩放(rescale)与键组(Key Group)设计
欢迎分享,转载请注明来源:内存溢出
一个flink程序,如下,但是总共100多个task,然后只有一个没有数据。
第一怀疑是不是keyBy问题,上述看错了,然后以为有keyBy 然后参考文章:【Flink】Flink状态的缩放(rescale)与键组(Key Group)设计
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)