Flink SQL 现在只能在create table 语句中指定watermark,另外一种迂回的做法,就是参考一下Flink SQL
把Tabe转成流,然后在流上做清洗后再指定watermark

Reply via email to