Время приема Apache Flink, какой замок на стене?

Question

Интересно, какие настенные часы используются в случае конфигурации времени приема пищи в Apache Flink.

Здесь мы читаем, что время приема "назначает временные метки настенных часов для записей, как только они поступают в систему (в источнике)".

Если источник не параллельный, я предполагаю, что временные метки, связанные с входящими кортежами, полностью упорядочены, но что если я использую функцию параллельного источника?
Может ли быть так, что параллельный источник работает на 2 разных машинах, что позволяет использовать 2 разные настенные часы для отметок времени?

заранее спасибо

Answer 1

Время настенных часов соответствующей машины используется в качестве метки времени. Следовательно, вы можете получить несколько разных временных отметок, если часы машин не синхронизированы должным образом.

Обновить

Это также верно для нескольких источников, если они выполняются на разных машинах. Каждый источник будет использовать часы машины, на которой он работает, для назначения меток времени.