У меня есть поток NiFi с использованием версии 1.8.0 процессора PutSQL
.Когда я направляю на него ввод, почти все FlowFiles перенаправляются на «сбой», но я не вижу сообщений об ошибках в журнале.Мое намерение состоит в том, чтобы делать пакетные обновления, основываясь на том, что я видел в сообщении в блоге на , используя PutSQL для пакетных обновлений .Как выяснить, в чем причина сбоев?
Свойство SQL-оператора PutSQL
имеет значение
update CTRL.PART_QUEUE
set SN_PROCESS=(select SN_PROCESS from CTRL.PROCESS where PROCESS_DESC = 'Completed')
where SN_SEQUENCE=?
В восходящем направлении у меня есть процессор UpdateAttribute
, который устанавливает sql.args.1.value
на основе некоторой информации из FlowFile и *От 1012 * до 4 (целое число).
редактирование: добавление дополнительной конфигурации