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

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

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

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

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


apache-flink windowing
person affo    schedule 29.02.2016    source источник

Ответы (1)


arrow_upward
2
arrow_downward

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

Обновлять

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

person Till Rohrmann    schedule 29.02.2016
comment
Отлично спасибо. Итак, я должен поддерживать синхронизацию. Кроме того, то же самое может произойти не только с параллельным источником, но и с двумя разными источниками, я прав? Если да, не могли бы вы добавить этот факт к своему ответу? - person affo; 29.02.2016
comment
Да, ты прав. Если операторы разных источников работают на разных машинах, они будут использовать часы машины, на которой они работают. - person Till Rohrmann; 29.02.2016