刚刚看源码发现在1.12.0的时候tumblineEventTimeWindows中貌似引入了一个WindowStagger的东西。 大概看了下，和我的方案3思想类似。但这个从代码文档来看，貌似仅支持算子的分区级别，也就是单个并行实例仅仅 支持一个offset值。 我的方案3时基于key的hash的某种机制，使得某个key固定分散个某个offset值上。可以认为是将key哈希到[0, windowSize)范围的一个值作为offset。
yidan zhao <[email protected]> 于2021年8月26日周四 下午5:33写道： > 附语雀：https://www.yuque.com/sixhours-gid0m/ls9vqu/nhgrpw > > 如果有人做过类似的，有什么好的方案可以分享下。也可以看看我当前的几个方案是否符合我的预想。 >
