[To dev/1.3] Pipe: Fixed the problem of null pointer and incorrect Tablet format being modified during TSFile construction (apache#15602) (apache#15623)

luoluoyuyu · SyncGithubBot · commit 03188e9d77a0 · 2025-06-05T19:56:58.000+08:00
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java
@@ -549,10 +549,9 @@ private void writeTabletsIntoOneFile(
       for (int i = 0, size = tabletList.size(); i < size; ++i) {
         final Tablet tablet = tabletList.get(i);
 
-        // convert date value to int
-        // refer to
+        // convert date value to int refer to
         // org.apache.iotdb.db.storageengine.dataregion.memtable.WritableMemChunk.writeNonAlignedTablet
-        final Object[] values = tablet.values;
+        final Object[] values = Arrays.copyOf(tablet.values, tablet.values.length);
         for (int j = 0; j < tablet.getSchemas().size(); ++j) {
           final MeasurementSchema schema = tablet.getSchemas().get(j);
           if (Objects.nonNull(schema)
@@ -573,16 +572,16 @@ private void writeTabletsIntoOneFile(
                 new PartialPath(tablet.deviceId),
                 isTabletAlignedList.get(i),
                 tablet.getSchemas().stream()
-                    .map(MeasurementSchema::getMeasurementId)
+                    .map(m -> Objects.nonNull(m) ? m.getMeasurementId() : null)
                     .toArray(String[]::new),
                 tablet.getSchemas().stream()
-                    .map(MeasurementSchema::getType)
+                    .map(m -> Objects.nonNull(m) ? m.getType() : null)
                     .toArray(TSDataType[]::new),
                 // TODO: cast
                 tablet.getSchemas().toArray(new MeasurementSchema[0]),
                 tablet.timestamps,
                 tablet.bitMaps,
-                tablet.values,
+                values,
                 tablet.rowSize);
 
         final int start = 0;
