使用cdc的方式读取
mysql的更新数据,使用connect流的方式连接两个流,这样可以避免掉watermark才能触发计算的问题。建议在事实表join不到数据的时候
进行缓存用 onTime进行触发。



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

回复