Re: Flink sql calculate principle question

2022-03-09 Thread Martijn Visser
Hi JianWen, I think this explained in the documentation on Dynamic Tables [1] Does that answer your question? Best regards, Martijn [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/concepts/dynamic_tables/#query-restrictions On Wed, 9 Mar 2022 at 18:32, JianWen Huang wr

Flink sql calculate principle question

2022-03-09 Thread JianWen Huang
As we all know. Flink sql will be translated into streaming api. Look at a sql : SELECT color, sum(id) FROM T GROUP BY color. In the actual calculation, Flink will store the whole t-stream into the state, and a piece of data in the stream will trigger a full stream calculation. Or does the stat