1

我想知道在 Apache Flink 中配置摄取时间的情况下使用哪个挂钟。

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

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

先感谢您

4

1 回答 1

2

相应机器的挂钟时间用作时间戳。因此，如果机器的时钟未正确同步，您可能会获得多个不同的时间戳。

更新

如果它们在不同的机器上执行，这也适用于多个源。每个源将使用运行它的机器的时钟来分配时间戳。

于 2016-02-29T14:00:09.473 回答