spotless

Author: shuwenwei

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/DiskChunkLoader.java

@@ -24,7 +24,9 @@
 import org.apache.iotdb.db.storageengine.buffer.ChunkCache;
 import org.apache.iotdb.db.storageengine.dataregion.tsfile.TsFileID;
 import org.apache.iotdb.db.storageengine.dataregion.tsfile.TsFileResource;
+import org.apache.iotdb.db.utils.ObjectTypeUtils;
 
+import org.apache.tsfile.enums.TSDataType;
 import org.apache.tsfile.file.metadata.ChunkMetadata;
 import org.apache.tsfile.file.metadata.IChunkMetadata;
 import org.apache.tsfile.read.common.Chunk;
@@ -85,6 +87,14 @@ public IChunkReader getChunkReader(IChunkMetadata chunkMetaData, Filter globalTi
                   chunkMetaData.getStatistics(),
                   context);
 
+      final TsFileID tsFileID = getTsFileID();
+      if (tsFileID.regionId > 0 && chunkMetaData.getDataType() == TSDataType.OBJECT) {
+        chunk
+            .getHeader()
+            .setReplaceDecoder(
+                decoder -> ObjectTypeUtils.getReplaceDecoder(decoder, tsFileID.regionId));
+      }
+
       long t2 = System.nanoTime();
       IChunkReader chunkReader = new ChunkReader(chunk, globalTimeFilter);
       SeriesScanCostMetricSet.getInstance()

iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/object/ObjectTypeCompactionTest.java

@@ -234,8 +234,8 @@ public void testSettleCompaction() throws IOException, WriteProcessException {
     Assert.assertTrue(pair2.getRight().exists());
   }
 
-  private Pair<TsFileResource, File> generateTsFileAndObject(boolean seq, long timestamp, int regionIdInTsFile)
-      throws IOException, WriteProcessException {
+  private Pair<TsFileResource, File> generateTsFileAndObject(
+      boolean seq, long timestamp, int regionIdInTsFile) throws IOException, WriteProcessException {
     TsFileResource resource = createEmptyFileAndResource(seq);
     Path testFile1 = Files.createTempFile(regionDir.toPath(), "test_", ".bin");
     byte[] content = new byte[100];