Re: Flink SQL Count Distinct performance optimization

2020-01-07 Thread
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

Re: [DISCUSS] Set default planner for SQL Client to Blink planner in 1.10 release

2020-01-05 Thread
+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. > >

回复:Compound Time interval in SQL queries

2019-11-21 Thread (晓令)
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 发送

回复:Compound Time interval in SQL queries

2019-11-21 Thread (晓令)
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

回复:Compound Time interval in SQL queries

2019-11-21 Thread (晓令)
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 ---