Re: Blink window and cube

2020-04-28 Thread 刘建刚
internal.StreamTableEnvironmentImpl.toDataStream(StreamTableEnvironmentImpl.java:351) > at > org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl.toRetractStream(StreamTableEnvironmentImpl.java:296) > at > org.apache.flink.table.api.java.internal.StreamTableEnvi

Re: Blink window and cube

2020-04-28 Thread Jark Wu
Thanks for reporting this. I think this is a missing feature. We need to do something in the optimizer to make this possible. Could you please help to create a JIRA issue for this? Best, Jark On Tue, 28 Apr 2020 at 14:55, 刘建刚 wrote: > Hi, I find that blink planner supports CUBE. CUBE can

Blink window and cube

2020-04-28 Thread 刘建刚
Hi, I find that blink planner supports CUBE. CUBE can be used together with a field but not window. For example, the following SQL is not supported: SELECT A, B, sum(C) FROM person GROUP BY cube(A, B), TUMBLE(curTimestamp, interval '1' minute) The following error is reported. Is