(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Fixed the issue where partial writing caused the measurement to be null and caused the memory estimator to throw NPE (#14391) (#14488)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 0a004693899 [To dev/1.3] Pipe: Fixed the issue where partial writing 
caused the measurement to be null and caused the memory estimator to throw NPE 
(#14391) (#14488)
0a004693899 is described below

commit 0a0046938997b6ba882519dd0fe75cc553f66060
Author: Zhenyu Luo <luoluoyuyu2...@gmail.com>
AuthorDate: Wed Dec 18 18:57:22 2024 +0800

    [To dev/1.3] Pipe: Fixed the issue where partial writing caused the 
measurement to be null and caused the memory estimator to throw NPE (#14391) 
(#14488)
    
    Co-authored-by: Tian Jiang <jt2594...@163.com>
---
 .../iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimator.java       | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimator.java
index 7883dda30a3..d577ddd8f2b 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimator.java
@@ -708,6 +708,9 @@ public class InsertNodeMemoryEstimator {
         RamUsageEstimator.alignObjectSize(
             NUM_BYTES_ARRAY_HEADER + NUM_BYTES_OBJECT_REF * columns.length);
     for (int i = 0; i < columns.length; i++) {
+      if (measurementSchemas[i] == null || measurementSchemas[i].getType() == 
null) {
+        continue;
+      }
       switch (measurementSchemas[i].getType()) {
         case INT64:
         case TIMESTAMP: