贴下代码，看下你是怎么使用的
| | 刘小红 | | [email protected] | 签名由网易邮箱大师定制 在2021年1月15日 17:40，xufengfeng<[email protected]> 写道： 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/ 会不会是数据里时间有未来时间呢?我之前遇到过一次
