(tsfile) branch column_builder_compatibility updated: fix getVisibleMetadataList

[ji...@apache.org]

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

jiangtian pushed a commit to branch column_builder_compatibility
in repository https://gitbox.apache.org/repos/asf/tsfile.git


The following commit(s) were added to refs/heads/column_builder_compatibility by this push:
     new 5ecf0859 fix getVisibleMetadataList
5ecf0859 is described below

commit 5ecf0859f51567febb853c7be00e7ef0daaa6169
Author: Tian Jiang <jt...@163.com>
AuthorDate: Fri Jan 10 17:32:43 2025 +0800

    fix getVisibleMetadataList
---
 .../org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java     | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/java/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java b/java/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java
index 5fb2eb6c..e01b741c 100644
--- a/java/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java
+++ b/java/tsfile/src/main/java/org/apache/tsfile/write/writer/RestorableTsFileIOWriter.java
@@ -193,10 +193,7 @@ public class RestorableTsFileIOWriter extends TsFileIOWriter {
     if (metadatasForQuery.containsKey(deviceId)
         && metadatasForQuery.get(deviceId).containsKey(measurementId)) {
       for (ChunkMetadata chunkMetaData : metadatasForQuery.get(deviceId).get(measurementId)) {
-        // filter: if a device'measurement is defined as float type, and data has been persistent.
-        // Then someone deletes the timeseries and recreate it with Int type. We have to ignore
-        // all the stale data.
-        if (dataType == null || dataType.equals(chunkMetaData.getDataType())) {
+        if (dataType == null || dataType.isCompatible(chunkMetaData.getDataType())) {
           chunkMetadataList.add(chunkMetaData);
         }
       }