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

justinchen pushed a commit to branch lower_version_compatibility
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/lower_version_compatibility by 
this push:
     new ee6f9ab2ec9 older_version_compatibility
ee6f9ab2ec9 is described below

commit ee6f9ab2ec9d4daf7c7f7a3e3b39ec3b1977c8ce
Author: Caideyipi <[email protected]>
AuthorDate: Mon Dec 1 16:44:33 2025 +0800

    older_version_compatibility
---
 .../apache/iotdb/db/pipe/sink/util/sorter/PipeTabletEventSorter.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/sorter/PipeTabletEventSorter.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/sorter/PipeTabletEventSorter.java
index c9857c9eaba..4ad64ae278b 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/sorter/PipeTabletEventSorter.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/sorter/PipeTabletEventSorter.java
@@ -27,6 +27,7 @@ import org.apache.tsfile.write.record.Tablet;
 import org.apache.tsfile.write.schema.IMeasurementSchema;
 
 import java.time.LocalDate;
+import java.util.Objects;
 
 public class PipeTabletEventSorter {
 
@@ -84,6 +85,10 @@ public class PipeTabletEventSorter {
       final TSDataType dataType,
       final BitMap originalBitMap,
       final BitMap deDuplicatedBitMap) {
+    // Older version's sender may contain null values, we need to cover this 
case
+    if (Objects.isNull(valueList)) {
+      return null;
+    }
     switch (dataType) {
       case BOOLEAN:
         final boolean[] boolValues = (boolean[]) valueList;

Reply via email to