Слияние Json после нескольких расколов в Nifi

Question

Я разделил свой Json несколько раз, чтобы избежать ошибок OOM.Я установил процессор Wait для ожидания всех моих записей для использования контента слияния.Каждой FF был присвоен атрибут числа строк исходного файла.

Процессор ожидания должен перевести FF в ожидание, пока уведомление не увеличит счетчик до общего числа строк.

ОднакоПохоже, мой процессор ожидания не помещает мою FF в очередь ожидания (она не отображается, но есть).

Что-то не так в этом состоянии потока?

Answer 1

Вы можете сделать несколько слияний, используя UpdateAttribute после каждого Split, чтобы сохранить атрибуты fragment.* как что-то другое, возможно, fragment1.*, fragment2.* и т. Д. Затем вы можете восстановить каждый из них в обратном порядке с UpdateAttribute перед каждымСлияние, установка fragment.* для атрибутов fragment2.*, затем MergeContent, затем установка fragment.* для атрибутов fragment1.*, затем MergeContent и т. Д.