我想知道在apache flink的摄取时间配置中使用了哪个挂钟。在这里，我们看到摄取时间“在记录到达系统（在源位置）时为记录分配挂钟时间戳”。如果源是非并行的，我假设与传入元组相关联的时间戳是完全有序的，但是如果我使用并行源函数呢？并行源是否可以在两台不同的机器上运行，从而可以使用两个不同的挂钟作为时间戳？先谢谢你
cbjzeqam1#
各机器的挂钟时间用作时间戳。因此，如果机器的时钟没有正确同步，您可能会得到多个不同的时间戳。
如果在不同的机器上执行多个源，那么这也适用于多个源。每个源将使用运行它的机器的时钟来分配时间戳。
1条答案
按热度按时间cbjzeqam1#
各机器的挂钟时间用作时间戳。因此，如果机器的时钟没有正确同步，您可能会得到多个不同的时间戳。
更新
如果在不同的机器上执行多个源，那么这也适用于多个源。每个源将使用运行它的机器的时钟来分配时间戳。