Я создал процессор для извлечения некоторых записей из БД и помещения их в корзину S3. Полученный файл имеет размер 480 МБ. Мой порог очереди составляет 1 ГБ. Выполнение Sql процессора заняло около 40 минут, чтобы получить детали. После того, как я оставил процессор Execute Sql на некоторое время (около 1 часа), Nifi застрял и получил ошибку ниже при попытке очистить очередь. Из немногих исследований я обнаружил, что эта проблема из-за дисбактериальной проблемы. Но nifi развернут в aws Ec2 размером 32 ГБ.
Не удалось удалить FlowFiles из-за java .lang.IllegalStateException: Невозможно обновить файл журнала ./flowfile_repository/journals/9894.journal из-за отсутствия заголовка уже написано.
Может кто-нибудь помочь.