Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.9.0
-
None
-
None
Description
Got an NPE in MergeRecord. Even after a restart, the processor won't resume processing data. Even copies of the processor won't process data.
Configuration:
Record Reader: JsonTreeReader Record Writer: AvroRecordSetWriter Merge Strategy: Bin-Packing Algorithm Correlation Attribute Name: No value set Attribute Strategy: Keep Only Common Attributes Minimum Number of Records: 10000 Maximum Number of Records: 20000 Minimum Bin Size: 0 B Maximum Bin Size: No value set Max Bin Age: 10 sec Maximum Number of Bins: 10
Stack Trace:
MergeRecord[id=ef343265-5156-1564-92fa-8f74649fb548] Failed to merge FlowFiles to create new bin due to java.lang.NullPointerException: java.lang.NullPointerException java.lang.NullPointerException: null at org.apache.nifi.processors.standard.merge.RecordBin.complete(RecordBin.java:340) at org.apache.nifi.processors.standard.merge.RecordBinManager.handleCompletedBins(RecordBinManager.java:272) at org.apache.nifi.processors.standard.merge.RecordBinManager.completeExpiredBins(RecordBinManager.java:238) at org.apache.nifi.processors.standard.MergeRecord.onTrigger(MergeRecord.java:350) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1161) 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
Attachments
Issue Links
- links to