只存计算结果，来一条数据更新一次状态并且下发出去。具体可以参考下state： https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/state/
hjw <1010445...@qq.com.invalid> 于2022年3月9日周三 01:32写道： > 如下一段sql：SELECT color, sum(id) FROM T GROUP BY > colorFlink在实际计算中会将T流整个存入状态里，流中来一条数据触发一次全流计算。亦或是状态只存计算结果，来了新的一条数据，在原来同group > by key（color)结果进行加减即可。这种具体Flink的运行机制请问有文档翻阅或者有规律进行总结吗?谢谢。
