Я хочу задержать поток файлов.Для этого я использую процессор ExecuteScript со следующим кодом:
flowFile = session.get()
if(!flowFile) return
session.penalize(flowFile)
session.transfer(flowFile, REL_SUCCESS)
Он просто штрафует файл потока на определенное время.Однако, как вы видите на рисунке, следующий процессор UpdateAttribute накапливает задачу / время.
Почему это происходит?Поступает ли файл потока в процессор UpdateAttribute, который распознает, что файл потока оштрафован, тем самым заставляя процессор выполнять некоторую работу?О чем беспокоиться?