Flink计算机制疑问

[hjw <10...@qq.com.INVALID>]

如下一段sql：SELECT color, sum(id) FROM T GROUP BY colorFlink在实际计算中会将T流整个存入状态里，流中来一条数据触发一次全流计算。亦或是状态只存计算结果，来了新的一条数据，在原来同group by key（color)结果进行加减即可。这种具体Flink的运行机制请问有文档翻阅或者有规律进行总结吗?谢谢。

回复： Flink计算机制疑问

[hjw <10...@qq.com.INVALID>]

这是streaming api 的文档说明。其实我更想了解sql api 在经过生成逻辑计划和物理计划后翻译为streaming api的实现。




------------------ 原始邮件 ------------------
发件人:                                                                                                                        "user-zh"                                                                                    <liujiangangpeng@gmail.com&gt;;
发送时间:&nbsp;2022年3月9日(星期三) 下午2:47
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: Flink计算机制疑问



只存计算结果，来一条数据更新一次状态并且下发出去。具体可以参考下state：
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/state/

hjw <1010445050@qq.com.invalid&gt; 于2022年3月9日周三 01:32写道：

&gt; 如下一段sql：SELECT color, sum(id) FROM T GROUP BY
&gt; colorFlink在实际计算中会将T流整个存入状态里，流中来一条数据触发一次全流计算。亦或是状态只存计算结果，来了新的一条数据，在原来同group
&gt; by key（color)结果进行加减即可。这种具体Flink的运行机制请问有文档翻阅或者有规律进行总结吗?谢谢。

Re: Flink计算机制疑问

[Jiangang Liu <li...@gmail.com>]

只存计算结果，来一条数据更新一次状态并且下发出去。具体可以参考下state：
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/state/

hjw <10...@qq.com.invalid> 于2022年3月9日周三 01:32写道：

> 如下一段sql：SELECT color, sum(id) FROM T GROUP BY
> colorFlink在实际计算中会将T流整个存入状态里，流中来一条数据触发一次全流计算。亦或是状态只存计算结果，来了新的一条数据，在原来同group
> by key（color)结果进行加减即可。这种具体Flink的运行机制请问有文档翻阅或者有规律进行总结吗?谢谢。