From 8798989fab861db066f970a14299ea4b101416cd Mon Sep 17 00:00:00 2001 From: Steve Yurong Su Date: Fri, 22 Nov 2024 19:44:24 +0800 Subject: [PATCH] Update PipeHistoricalDataRegionTsFileAndDeletionExtractor.java --- .../PipeHistoricalDataRegionTsFileAndDeletionExtractor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionExtractor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionExtractor.java index 5251107bf172..c10d2ebefc3e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionExtractor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionExtractor.java @@ -673,22 +673,22 @@ private boolean mayTsFileResourceOverlappedWithPattern(final TsFileResource reso || deviceID.getTableName().startsWith(TREE_MODEL_EVENT_TABLE_NAME_PREFIX) || deviceID.getTableName().equals(PATH_ROOT)) { // In case of tree model deviceID + updateIsDbNameCoveredByPattern(resource, false); if (treePattern.isTreeModelDataAllowedToBeCaptured() && treePattern.mayOverlapWithDevice(deviceID)) { tsfile2IsTableModelMap.computeIfAbsent( resource, (tsFileResource) -> Boolean.FALSE); - updateIsDbNameCoveredByPattern(resource, false); return true; } } else { // In case of table model deviceID + updateIsDbNameCoveredByPattern(resource, true); if (tablePattern.isTableModelDataAllowedToBeCaptured() // The database name in resource is prefixed with "root." && tablePattern.matchesDatabase(resource.getDatabaseName().substring(5)) && tablePattern.matchesTable(deviceID.getTableName())) { tsfile2IsTableModelMap.computeIfAbsent( resource, (tsFileResource) -> Boolean.TRUE); - updateIsDbNameCoveredByPattern(resource, true); return true; } }