Hi
all，在Flink1.11里面新增了WatermarkStetagy来处理某个并行度下没有数据导致watermark不触发的问题，在1.10里面Flink有什么机制解决这个问题吗？谢谢
| |
BenChen
|
|
haibin...@163.com
|
签名由网易邮箱大师定制
Hi all，
在FlinkSQL中，我知道可以通过group by window去做窗口处理，但是如果触发时间和窗口时间不一致，如何去表达呢？
比如说，统计一天的PV和UV，每隔10S更新数据，在StreamingApi里面，可以通过timeWindow(1Day) +
trigger(10Seconds)去实现，但是到FlinkSQL上要如何实现呢？
感激不尽。
| |
BenChen
|
|
haibin...@163.com
|
签名由网易邮箱大师定制
??
uid
keybyreduce??aggregatestateBloomFilterWindowFunction??stateprocess
| |
BenChen
|
|
haibin...@163.com
|
??
??2020??06??30?? 15:55
的问题是
1. 是否从Flink设计角度来说，就不支持在reduce和aggregate使用RichFunction？还是说以后会实现？
2. Flink自带的RichReduceFunction和RichAggregateFunction是用在什么场景？
3.
在使用reduce和aggregate聚合的过程中，如果我需要一些全局的state，比如使用BloomFilter判断用户是否参与过这个活动，有什么建议吗？
感谢。
| |
BenChen
|
|
haibin...@163.com
|
签名由网易邮箱大师定制
