[
https://issues.apache.org/jira/browse/NIFI-9391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Turcsanyi updated NIFI-9391:
----------------------------------
Labels: stateless (was: )
> MergeRecord does not work in stateless flows
> --------------------------------------------
>
> Key: NIFI-9391
> URL: https://issues.apache.org/jira/browse/NIFI-9391
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Reporter: Peter Turcsanyi
> Assignee: Peter Turcsanyi
> Priority: Major
> Labels: stateless
> Time Spent: 10m
> Remaining Estimate: 0h
>
> The stateless runtime triggers a processor up until FFs are available in the
> upstream queue.
> MergeRecord needs an extra onTrigger() call where session.get() yields no
> result in order to get notified that no more FFs are available and it is time
> to send the merged FF downstream. This extra call will never happen in
> stateless environment and MergeRecord cannot send out FF in this way.
> Modify MergeRecord to run session.get() in a loop within a single onTrigger()
> call like MergeContent does:
> {code:java}
> while (binManager.getBinCount() <=
> context.getProperty(MAX_BIN_COUNT).asInteger()) {
> if (!isScheduled()) {
> break;
> }
> final ProcessSession session = sessionFactory.createSession();
> final List<FlowFile> flowFiles = session.get(1000);
> if (flowFiles.isEmpty()) {
> break;
> }
> ...
> {code}
> NIFI-9390 also affects MergeContent when it is not in the starting position
> in the flow but this jira needs to be fixed first (otherwise the other cannot
> pop up).
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
