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

PutElasticsearchRecord should make it easier for users to distinguish between Records that resulted in Elasticsearch errors and those that did not

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 1.14.0
    • 1.16.0
    • None
    • None

    Description

      The PutElasticsearchRecord processor will currently optionally log Records from the input FlowFile that were marked as resulting in an error within Elasticsearch; these same Records can optionally be directed to the errors Relationship from the Processor if the user provides an appropriate Error Record Writer.

      The original input FlowFile is always sent to the success Relationship irrespective of whether any/all Records resulted in Elasticsearch errors (unless the call to Elasticsearch itself fails, in which case the FlowFile is routed to failure or retry depending upon the Exception type).

      It would be more useful if the Records that did not result in errors were also written to a Relationship such that users could process those separate to the errored Records without having to try and find them from the original input. This would more closely mirror what is already done as part of the PutElasticsearchHttpRecord processor, which separates Records between the success and failed Relationships depending upon the Elasticsearch responses for each Record.

      Attachments

        1. NIFI-9581.xml
          44 kB
          Chris Sampson
        2. NIFI-9581.json
          22 kB
          Chris Sampson

        Issue Links

          Activity

            People

              Chris S Chris Sampson
              Chris S Chris Sampson
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 3.5h
                  3.5h