You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@nifi.apache.org by "Ameya Shendre (Jira)" <ji...@apache.org> on 2023/11/02 18:30:00 UTC

[jira] [Created] (NIFI-12312) ForkEnrichment & JoinEnrichment in Stateless NiFi

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)