回复： kafka 所有分区无数据的情况下，导致watermark无法前进

2021-01-27 文章 刘小红
可以调用WatermarkStrategy.withIdleness(Duration idleTimeout) 指定空闲超时时间，这样不会影响水印的进度，进而影响下游算子操作 | | 刘小红 | | 18500348...@163.com | 签名由网易邮箱大师定制 在2021年1月28日 14:42，wpp<1215303...@qq.com> 写道： 可以按照proceeTime来处理吧 -- Sent from: http://apache-flink.147419.n8.nabble.com/

回复： flink sql 消费kafka 消息 写入Hive不提交分区

2021-01-15 文章 刘小红
贴下代码，看下你是怎么使用的 | | 刘小红 | | 18500348...@163.com | 签名由网易邮箱大师定制 在2021年1月15日 17:40，xufengfeng<503814...@qq.com> 写道： 2021年1月15日 下午3:19，花乞丐 写道： 我这边从kafka消费信息，然后写入到Hive中，目前发现不提交分区，不提交分区的原因是watemark是负数的，不清楚这个负数的watermark是怎么出现的？ <http://apache-flink.147419.n8.nabble.com/file/t1257/E4142DB1-