Hi all， 在flink里面尝试使用RichReduceFunction和RichAggregateFunction，但是收到了UnsupportedOperationException。
看了下源代码，在reduce和aggregate方法里面会检测到是RichFunction的话就会直接抛异常。同时ReduceFunction和AggregateFunction是作为ReducingState和AggregatingState的属性，作为函数的聚合方法，真正让用户使用state是要放到reduce和aggregate对应的WindowFunction参数里面去。 目前我的问题是 1. 是否从Flink设计角度来说，就不支持在reduce和aggregate使用RichFunction？还是说以后会实现？ 2. Flink自带的RichReduceFunction和RichAggregateFunction是用在什么场景？ 3. 在使用reduce和aggregate聚合的过程中，如果我需要一些全局的state，比如使用BloomFilter判断用户是否参与过这个活动，有什么建议吗？ 感谢。 | | BenChen | | haibin...@163.com | 签名由网易邮箱大师定制
