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

When a processor pulls a batch of FlowFiles, it keeps pulling from the same inbound connection instead of round-robin'ing

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      When a Processor calls ProcessSession.get(int) or ProcessSession.get(FlowFileFilter), the FlowFiles only come from the first inbound connection, unless that connection is empty or doesn't have enough FlowFiles to complete the get() call. It should instead round-robin between the incoming connections, just as ProcessSession.get() does.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            pvillard Pierre Villard
            markap14 Mark Payne
            Votes:
            0 Vote for this issue
            Watchers:
            7 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Issue deployment