多谢各位的耐心回答，我已经找到问题了，目前是水印使用有点问题，是我自己的问题，不好意思各位 <http://apache-flink.147419.n8.nabble.com/file/t1257/%E4%BD%BF%E7%94%A8%E5%A7%BF%E5%8A%BF.jpg> 修改之后，发现还是无法提交分区数据，经调试发现，watermark值目前是ok,但是其次是，由于Flink的toMills方法使用的UTC时间，导致我们从分区提取值时，比原始值大了8个小时，因此，导致水印一直小于 partition_time+commitDelay。接下来进行相应处理即可。 <http://apache-flink.147419.n8.nabble.com/file/t1257/%E6%97%B6%E5%8C%BA%E9%97%AE%E9%A2%98.jpg>
-- Sent from: http://apache-flink.147419.n8.nabble.com/
