fix cached time chunk flip twice

apache · Oct 24, 2024 · 58302c9 · 58302c9
1 parent 4e79200
commit 58302c9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...eengine/dataregion/compaction/execute/utils/executor/batch/utils/BatchCompactionPlan.java b/...eengine/dataregion/compaction/execute/utils/executor/batch/utils/BatchCompactionPlan.java
@@ -51,14 +51,15 @@ public Chunk getTimeChunkFromCache(TsFileSequenceReader reader, ChunkMetadata ch
     if (chunk == null) {
       chunk = reader.readMemChunk(chunkMetadata);
     }
-    chunk.getData().flip();
+    chunk.getData().reset();
     return chunk;
   }
 
   public void addTimeChunkToCache(String file, long offset, Chunk chunk) {
     if (cachedTimeChunkSize >= MAX_CACHED_TIME_CHUNKS_SIZE) {
       return;
     }
+    chunk.getData().mark();
     cachedTimeChunks.put(
         new Pair<>(file, offset),
         new Chunk(