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

PutElasticsearchRecord has fatal error processing record set

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.11.0
    • Fix Version/s: 1.11.0
    • Component/s: None
    • Labels:
      None

      Description

      Stacktrace observed during a test for the 1.11 release vote:

       

      ava.lang.IllegalStateException: StandardFlowFileRecord[uuid=f2dd3700-80b5-4bd0-8b07-ed2bb8f23028,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1579307885285-33, container=default, section=33], offset=14115, length=2256263],offset=0,name=201506.mbox,size=2256263] already in use for an active callback or an InputStream created by ProcessSession.read(FlowFile) has not been closed
      at org.apache.nifi.controller.repository.StandardProcessSession.validateRecordState(StandardProcessSession.java:3245)
      at org.apache.nifi.controller.repository.StandardProcessSession.validateRecordState(StandardProcessSession.java:3240)
      at org.apache.nifi.controller.repository.StandardProcessSession.transfer(StandardProcessSession.java:1999)
      at org.apache.nifi.processors.elasticsearch.PutElasticsearchRecord.onTrigger(PutElasticsearchRecord.java:228)
      at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
      at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1176)
      at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:213)
      at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
      at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
      at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
      at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
      at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      at java.lang.Thread.run(Thread.java:748)

        Attachments

          Activity

            People

            • Assignee:
              mike.thomsen Mike Thomsen
              Reporter:
              mike.thomsen Mike Thomsen
            • Votes:
              0 Vote for this issue
              Watchers:
              3 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 - 1h
                1h