Ameya Shendre created NIFI-12312:
------------------------------------
Summary: ForkEnrichment & JoinEnrichment in Stateless NiFi
Key: NIFI-12312
URL: https://issues.apache.org/jira/browse/NIFI-12312
Project: Apache NiFi
Issue Type: Bug
Components: NiFi Stateless
Affects Versions: 1.19.1
Reporter: Ameya Shendre
I have a standard flow like the one mentioned in here:
[https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.23.2/org.apache.nifi.processors.standard.ForkEnrichment/additionalDetails.html]
Basically, ForkEnrichment then enrichment over HTTP and then JoinEnrichment of
original & enriched data using the WRAPPER strategy.
I'm trying to run this flow using the 1.19.1 NiFi Stateless engine.
Since the NiFi Stateless engine is single-threaded, I'm observing that
JoinEnrichment first gets timed out on the original Flow File & then on the
enriched flow file. It's not able to run enrichment in parallel & then Join
them since it never has 2 flow files in the bin.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
