diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileSource.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileSource.java index 91f5be62f1153..8543a103e321b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileSource.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileSource.java @@ -486,6 +486,11 @@ private boolean mayTsFileContainUnprocessedData(final TsFileResource resource) { } private boolean mayTsFileResourceOverlappedWithPattern(final TsFileResource resource) { + // Trimming to avoid unnecessary file device getter + if (isDbNameCoveredByPattern) { + return true; + } + final Set deviceSet; try { final Map deviceIsAlignedMap =