Как мне найти причину сбоев PutSQL? - PullRequest
0 голосов
/ 28 февраля 2019

У меня есть поток 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 (целое число).

редактирование: добавление дополнительной конфигурации

  • Пул соединений JDBC: настроен для взаимодействия с SQL Server
  • Поддержка фрагментированных транзакций: true
  • Время ожидания транзакции:значение не задано
  • Размер партии: 100
  • Получить сгенерированные ключи: false
  • Откат при сбое: false

  • Отношения успеха и неудачи автоматически прекращаются;повтор повторяется обратно в тот же процессор

...