Re: flink sql 消费kafka 消息 写入Hive不提交分区

Fri, 15 Jan 2021 01:41:10 -0800 


> 2021年1月15日 下午3:19，花乞丐 <[email protected]> 写道：
> 
> 我这边从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/
会不会是数据里时间有未来时间呢?我之前遇到过一次





















					回复