引入随机key最大问题是,本身希望batch方式sink,key太随机压根无法batch。 如果randomKey%1024这样分桶到1024的话,也不行,会导致每个bucket中数据量太少,进而基本都是timeout而sink,而不是达到batchSize,换言之,每次sink都会有1024个并发sink次数。 实际后端的存储可能不期望这么高并发,本身做batch的目的就是希望降低sink次数。 我希望的是按照并发度(比如30并发度)就每次sink30次(或超过30次,因为可能>batchSize,如果都<batchSize,则30个并发都超时sink,也就是一次触发会30次sink)。
yidan zhao <hinobl...@gmail.com> 于2021年2月9日周二 下午3:04写道: > 如题,当前flink不支持非keyedStream使用定时器,不清楚有啥解决方法吗? > > 目前我实现一个sink,带超时希望用到timerservice。但是不支持。 > 同时不希望使用keyedStream,因为会导致数据不均衡。 > > 除了引入随机key外还有什么方法吗。 >