这个我也不太清楚,没有做过对应的是测试。

@吴磊 想到一个问题,如果 process 中使用了 agg state,keyBy(userId % 10) 后会有问题吧?使用 mapState 做 
agg 操作? 
在2020年12月6日 20:30,赵一旦<[email protected]> 写道:
所以说,ckpt的性能/时间和key的数量有关对吗?即使总体数据量不变,key少些,每个key的状态变大,会降低ckpt时间?
按照你们的分析来看??

bradyMk <[email protected]> 于2020年12月4日周五 下午7:23写道:

对对对,可以取hashCode,我短路了,谢谢哈~



-----
Best Wishes
--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复