个人理解有几种实现方案
1、通过主键加LAST_VALUE()使用最新的记录进行计算
2、通过flink-cdc connector source
3、自己根据操作类型写计算逻辑




--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复