Apache Flink 的 ingestion time，哪个墙锁？

Question

我想知道在 Apache Flink 中 ingestion time 配置的情况下使用哪个挂钟。

Here，我们读到摄取时间“记录一到达系统（在源）就将挂钟时间戳分配给记录”。

如果源是 non parallel 我假设与传入元组关联的时间戳是完全有序的，但是如果我使用 parallel源函数？
难道并行源在 2 台不同的机器上运行，从而可以使用 2 个不同的挂钟 作为时间戳？

提前致谢

Answer 1

各个机器的挂钟时间用作时间戳。因此，如果机器的时钟没有正确同步，您可能会得到多个不同的时间戳。

更新

这也适用于在不同机器上执行的多个源。每个源将使用其所在机器的时钟 运行 分配时间戳。