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 <jianwen.huang....@gmail.com> wrote: > 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 status save only the calculation > results and a new piece of data comes in the same group by key (color) > the result can be added or subtracted. Is there a document or regular > summary of the specific operation mechanism of Flink?thx. >
