[IOTDB-4405] ext-pipe kafka plugin trigger NullPointerException

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Component/s: Core/Others
• Assignee: Bo Zhang
• Reporter: Bo Zhang
• Created: 14/Sep/22 06:25
• Updated: 26/Sep/22 06:21
• Resolved: 26/Sep/22 06:21

Description

ext-pipe kafka plugin PR is: https://github.com/apache/iotdb/pull/6688

The exception call-trace is as below:

===============================================

6201 [pool-9-IoTDB-ExtPipePlugin-Worker-kafkasink-1] ERROR o.a.i.d.s.e.ExtPipePlugin - Unexpected system exception 
java.lang.NullPointerException: null
 at org.apache.iotdb.tsfile.file.header.PageHeader.getNumOfValues(PageHeader.java:105)
 at org.apache.iotdb.db.sync.datasource.TsFileOpBlock.getNonAlignedChunkPoints(TsFileOpBlock.java:356)
 at org.apache.iotdb.db.sync.datasource.TsFileOpBlock.getChunkPoints(TsFileOpBlock.java:582)
 at org.apache.iotdb.db.sync.datasource.TsFileOpBlock.getOperation(TsFileOpBlock.java:691)
 at org.apache.iotdb.db.sync.datasource.PipeOpSgManager.getOperation(PipeOpSgManager.java:101)
 at org.apache.iotdb.db.sync.datasource.PipeOpManager.getOperation(PipeOpManager.java:173)
 at org.apache.iotdb.db.sync.externalpipe.ExtPipePlugin$DataTransmissionTask.call(ExtPipePlugin.java:496)
 at org.apache.iotdb.db.sync.externalpipe.ExtPipePlugin$DataTransmissionTask.call(ExtPipePlugin.java:312)
 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
 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:750)