我在一个job中有一些很大的数据（key的种类很少，但是单个key下的数据数量很多），基本要实现的是一个时间滑动窗口结束时，当某个key的数量大于一个固定值后，将该key下的所有原数据输出。我现在的方法是将key加后缀，然后keyBy做窗口，但是这个做完之后还是需要再次keyBy把数据还原回去，并且这个过程又将全量数据拉到了一个节点上，请问有没有一些别的解决方法？
| | syumialiu | | [email protected] | 签名由网易邮箱大师定制
- 请教Flink中关于窗口的问题 syumialiu
- 请教Flink中关于窗口的问题 syumialiu
