Состояние ListSFTP не хранится в таблице HBase для HBase_1_1_2_ClientMapCacheService - PullRequest
0 голосов
/ 25 апреля 2018

Я создал HBase_1_1_2_ClientMapCacheService для хранения состояния от различных процессоров ListSFTP. Я создал таблицу HBase, в которой должно храниться состояние. После выполнения ListSFTP я сканирую таблицу, но в ней нет записей, но для процессора отображается состояние. Неправильно ли ожидать, что в таблице HBase будет запись о состоянии после выполнения ListSFTP?

1 Ответ

0 голосов
/ 25 апреля 2018

Давным-давно процессоры использовали распределенный кэш карт для хранения состояния, и многие из этих процессоров все еще имеют свойство поддерживать обратную совместимость. Обычно, если кто-то обновляет версию с 0.5 до 1.6, он попытается загрузить старое состояние из DMC и перенести его в новый API управления состоянием.

Текущий подход заключается в том, что инфраструктура NiFi предоставляет StateManager для процессоров, которые можно использовать для хранения состояния. Используемый менеджер состояний настраивается в файле state-management.xml.

Когда вы работаете в автономном NiFi, диспетчер состояний является локальным журналом записи с опережением, когда вы кластеризуетесь, это по умолчанию ZooKeeper, и есть опция для Redis.

Если вы щелкнете правой кнопкой мыши по процессору и выберете View State, вы увидите, какое состояние сохранено для процессора, которое будет получено из диспетчера состояний.

...