watermark疑问

来源：7-16 Flink watermark概述

bking3629688

2021-04-27

老师，我按照你讲的文章。把他的代码在本地运行了一下。
按照我的理解，第二条输出最后的水位就应该是 141756862000- 10000 = 141756852000。
下面这张文章里的图运行结果也是如此
图片描述

但我实际运行结果如下图所示，第1~第8条都是-10000，第9条记录开始watermark才开始有变化（无论输入什么时间都是第9条开始正常）。这是什么原因导致的呢？代码完全copy的文章。还是说这是1.12版本的新特性？
图片描述

写回答

1回答

bking3629688

提问者

2021-04-27

想到8这个数字有点特别，猜测是并行度。把全局并行度设置为1后，就正常输出watermark了。

文章中没有提及并行度对结果的影响，绕了很大一圈。

bking3629688

Michael_PK

原来如此，谢谢~

2021-04-28

共2条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

相似问题

回答 1

回答 1

回答 1

回答 1

回答 1