У меня кластерная настройка nifi, и мы запускаем процессор GetMongo с включенным основным режимом, чтобы дублированные данные не выбирались. Кажется, это работает нормально. Однако, получив эти данные, я хочу, чтобы следующие процессы в цепочке выполнялись в кластере, как при параллельной обработке этих данных, которые были получены. Почему-то этого не происходит. Поэтому мой вопрос ниже, если предположить, что GetMongo получил 30000 записей, и они находятся в очереди:
1) Как проверить, выполняет ли процессор свой процесс на одном узле или на всех узлах. Конфигурация была установлена для всех узлов, но когда процессор работает, я вижу, что он отображает 1 в верхнем правом углу.
2) Если один процессор настроен для работы только на основном узле, все остальные процессоры в потоке также работают в основном режиме?
Пример:
На скриншоте выше мой getmongo работает на основном узле, как мне убедиться, что процессор исполняемых скриптов работает параллельно на всех 3 узлах nifi. На данный момент, если я проверяю историю состояния просмотра в процессе исполняемого сценария, я вижу данные, проходящие только через основной узел.