GenerateTableFetch удаляет файл потока без данных для запроса

Question

Я использую GenerateTableFetch для входящих файлов потока, содержащих table_name, для импорта данных.И я поставил Additional WHERE clause для обработки добавочных обновлений, используя столбец updated_at таблицы вручную.

Проблема в том, что когда нет данных для импорта для составного запроса, он просто удаляет файл потока.Он должен иметь отдельную связь, отличную от успеха и неудачи для этого случая, чтобы я мог самостоятельно справиться, если что-то должно быть сделано для таких случаев.

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

Есть ли способ справиться с этим?

Answer 1

Это действительно было бы хорошим улучшением для добавления в GenerateTableFetch, возможно, необязательное свойство «Выводить пустой FlowFile при нулевых результатах» или что-то в этом роде.Я написал NIFI-5604 , чтобы описать это улучшение.Комбинируя это с NIFI-5601, вы могли бы выполнять маршрутизацию вниз по потоку (если фрагмент.count = 0, например).