Update PipeHistoricalDataRegionTsFileAndDeletionExtractor.java

apache · Nov 22, 2024 · 8798989 · 8798989
1 parent 4a7375d
commit 8798989
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...e/extractor/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionExtractor.java b/...e/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;
                 }
               }