mirror of https://github.com/apache/nifi.git
4346dd8faf
* NIFI-9391: Modified MergeRecord to process FlowFiles within a loop in a single onTrigger MergeRecord processed the FlowFiles in multiple onTrigger-s and it needed an extra onTrigger call (with no incoming FFs) to realize that no more FFs are available and it is time to send the merged FF downstream. It was not compatible with Stateless Runtime which does not trigger the flow any more if no FFs available. Also changed "unschedule" logic in StandardProcessorTestRunner: @OnUnscheduled methods were called immediately after the 1st FlowFile was processed. Unschedule the processor only at the end of the execution (onTrigger finished) and only if stopOnFinish has been requested by the test case. |
||
|---|---|---|
| .. | ||
| src | ||
| pom.xml | ||