В настоящее время я использую NiFi 1.9.2 в кластерной среде с 3 узлами. Недавно я заметил, что поток, кажется, застрял. Очередь показывает, что в очереди есть элементы, но ничто не переходит к нижестоящему процессору. Когда я перечисляю элементы в очереди, я получаю «У очереди нет FlowFiles».
Очередь в этом случае настроена на балансировку нагрузки с циклическим перебором. Если я остановлю нисходящий процессор и изменим конфигурацию в очереди, чтобы не балансировать нагрузку, а затем снова переключу его на циклический перебор, элементы очереди будут распределены по двум другим узлам, и я смогу увидеть файлы потока, когда я перечислюпредметы в очереди. Тем не менее, он только показывает элементы, как находящиеся в двух из узлов. Когда я перезагружаю нисходящий процессор, 2/3 элементов обрабатываются, оставляя 1/3, которая будет на узле, чьи элементы очереди я не вижу. Такое поведение сохраняется даже после перезапуска службы кластеров.
Если я изменю очередь на балансировку нагрузки, то все будет помещено на хороший узел, и очередь будет очищена. Похоже, что на моем первом узле что-то не так.
Любые предложения о том, что попробовать?
Спасибо,
-tj