[APEXMALHAR-2003] NPE in FileSplitterInput

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.4.0, 3.3.1
• Assignee: Chandni Singh
• Reporter: Vlad Rozov
• Created: 24/Feb/16 00:55
• Updated: 03/Mar/16 05:40
• Resolved: 25/Feb/16 21:51

Description

NPE in FileSplitterInput:

2016-02-23 16:50:12,171 [1/fileSplitter:FileSplitterInput] ERROR engine.StreamingContainer run - Operator set [OperatorDeployInfo[id=1,name=fileSplitter,type=INPUT,checkpoint={56ccee5c000000ef, 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=blocksMetadataOutput,streamId=blockin,bufferServer=d1xphdta0002.directv.com], OperatorDeployInfo.OutputDeployInfo[portName=filesMetadataOutput,streamId=filemeta,bufferServer=d1xphdta0002.directv.com]]]] stopped running due to an exception.

java.lang.NullPointerException

at com.datatorrent.lib.io.fs.AbstractFileSplitter$BlockMetadataIterator.next(AbstractFileSplitter.java:322)
at com.datatorrent.lib.io.fs.AbstractFileSplitter.emitBlockMetadata(AbstractFileSplitter.java:150)
at com.datatorrent.lib.io.fs.FileSplitterInput.replay(FileSplitterInput.java:137)
at com.datatorrent.lib.io.fs.FileSplitterInput.beginWindow(FileSplitterInput.java:122)
at com.datatorrent.stram.engine.InputNode.run(InputNode.java:116)
at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1380)
2016-02-23 16:50:14,124 [main] INFO engine.StreamingContainer processHeartbeatResponse - Undeploy request: [1]
2016-02-23 16:50:14,126 [main] INFO engine.StreamingContainer undeploy - Undeploy complete.