Uploaded image for project: 'Apache NiFi'
  1. Apache NiFi
  2. NIFI-12312

ForkEnrichment & JoinEnrichment in Stateless NiFi

    XMLWordPrintableJSON

Details

    Description

      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.

               

      Attachments

        Activity

          People

            Unassigned Unassigned
            ameyashendre Ameya Shendre
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: