我这边从kafka消费信息,然后写入到Hive中,目前发现不提交分区,不提交分区的原因是watemark是负数的,不清楚这个负数的watermark是怎么出现的?
<http://apache-flink.147419.n8.nabble.com/file/t1257/E4142DB1-E410-43e8-8653-2B90D0A998EA.png>
 
我代码也指定了watermark,但是debug的时候好像没有起作用



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

回复