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 <[email protected]>
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);
         }
       }

Reply via email to