这个我也不太清楚,没有做过对应的是测试。
@吴磊 想到一个问题,如果 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/
