我的测试结果时，把原先的丢弃掉，完全采用最新的逻辑。
原始邮件 发件人: lec ssmi<shicheng31...@gmail.com> 收件人: flink-user-cn<user-zh@flink.apache.org> 发送时间: 2020年4月17日(周五) 14:43 主题: Re: 为消息分配时间戳但不想重新分配水印 watermark的重新生成，是将新的watermark也加入到watermark队列，然后选出一个最值，还是将原先的watermark直接丢弃掉，改用新的？ taowang <taow...@deepglint.com> 于2020年4月17日周五 上午10:46写道： > 是的，是生效了的。没见到别人这样用过，在我的场景里这个操作是实现了我需要的逻辑，但会不会引起其他问题，我暂时还没有发现。 > > > 原始邮件 > 发件人: lec ssmi<shicheng31...@gmail.com> > 收件人: flink-user-cn<user-zh@flink.apache.org> > 发送时间: 2020年4月17日(周五) 09:25 > 主题: Re: 为消息分配时间戳但不想重新分配水印 > > > 请问，你对DataStream重新声明时间列和水印，生效吗？ taowang <taow...@deepglint.com> > 于2020年4月16日周四 下午10:49写道： > 嗯嗯，还是十分感谢。 > > 那我暂时就把这个问题先搁置了，至于issue和我们自己的实现，我自己有时间的时候就去提一个，并添加自己的实现。 > > > 打扰各位了，祝好！～ > > > > 原始邮件 > 发件人: tison<wander4...@gmail.com> > 收件人: user-zh< > user-zh@flink.apache.org> > 发送时间: 2020年4月16日(周四) 22:39 > 主题: Re: > 为消息分配时间戳但不想重新分配水印 > > > 正在载入邮件原文…
