目前source-》window-》sink到redis,sink并行度为5,是否会发生同一window数据到达不同slot的sink算子,由于网络延迟/堵塞导致先到sink的数据未被及时处理导致覆盖了后到的数据。
有没有同步控制呢?可以进行同步控制,前端接收到数据后,返回结果再处理下一个命令。
并行度不会,切分的小任务最终会合并。
延迟数据可能会导致数据顺序不一致。