hi sunfulin,
you can try with blink planner (since 1.9 +), which optimizes distinct
aggregation. you can also try to enable
*table.optimizer.distinct-agg.split.enabled* if the data is skew.
best,
godfreyhe
sunfulin 于2020年1月8日周三 下午3:39写道:
> Hi, community,
> I'm using Apache Flink SQL to build so
+1 for making the blink planner as default planner, the blink planner
becomes more stable since 1.10
Dian Fu 于2020年1月6日周一 上午11:51写道:
> +1 to set blink planner as the default planner for SQL client considering
> that so many features added since 1.10 are only available in the blink
> planner.
>
>
700:INTERVAL HOUR TO
MINUTE). While blink planner's approach is just the opposite. (simplify
expression first, and then transform window).
so, you could try blink planner.
thanks,
godfrey
--
发件人:Arujit Pradhan
发送
hi arujit,
Which Flink version are you using?
thanks,
godfrey
--
发件人:Arujit Pradhan
发送时间:2019年11月21日(星期四) 17:21
收件人:贺小令(晓令) ; user
主 题:Re: Compound Time interval in SQL queries
Hi, godfrey,
Thanks for your reply. But now I
please try this approach: interval + interval
like this:
SELECT count(1) AS event_count ,
TUMBLE_END(rowtime, INTERVAL '7' HOUR + INTERVAL '30' MINUTE) AS
window_timestamp
FROM `data_stream`
GROUP BY TUMBLE ( rowtime, INTERVAL '7' HOUR + INTERVAL '30' MINUTE)
thanks,
godfrey
---