Как создать пакетный идентификатор в пользовательском приемнике Spark? - PullRequest
0 голосов
/ 19 декабря 2018

Я пытаюсь идентифицировать партию в пользовательских приемниках.У каждого получателя должен быть одинаковый идентификатор на протяжении интервала между партиями.

Я стараюсь иметь таймер в каждом приемнике и начальное значение для первой партии.Затем я установил таймер для обновления идентификатора после интервала между партиями.Это может работать в течение некоторого времени.Однако, если какой-либо приемник выходит из строя, синхронизация нарушается.Есть ли способ получить точное время партии или событие в приемниках?

Можно ли использовать широковещательные переменные для их синхронизации?

Я ожидаю, что у каждого получателя будет одинаковый идентификатор партии.Неважно, что id является целым числом или строкой или чем-то еще.

...