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);
}
}