From 378d6ce34d0208e95eb8ab934f18f0caf60dd430 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BB=9F=E5=BC=8B?= Date: Tue, 26 May 2026 16:31:25 +0800 Subject: [PATCH] [core] Log when scanning with global index --- .../paimon/globalindex/DataEvolutionBatchScan.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/globalindex/DataEvolutionBatchScan.java b/paimon-core/src/main/java/org/apache/paimon/globalindex/DataEvolutionBatchScan.java index 51fa3520d781..8d6038ccc492 100644 --- a/paimon-core/src/main/java/org/apache/paimon/globalindex/DataEvolutionBatchScan.java +++ b/paimon-core/src/main/java/org/apache/paimon/globalindex/DataEvolutionBatchScan.java @@ -41,6 +41,9 @@ import org.apache.paimon.utils.Range; import org.apache.paimon.utils.RowRangeIndex; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import javax.annotation.Nullable; import java.io.IOException; @@ -57,6 +60,8 @@ /** Scan for data evolution table. */ public class DataEvolutionBatchScan implements DataTableScan { + private static final Logger LOG = LoggerFactory.getLogger(DataEvolutionBatchScan.class); + private final FileStoreTable table; private final DataTableBatchScan batchScan; @@ -274,7 +279,11 @@ private Optional evalGlobalIndex() { } try (GlobalIndexScanner scanner = optionalScanner.get()) { - return scanner.scan(filter); + Optional result = scanner.scan(filter); + if (result.isPresent()) { + LOG.info("Scan table '{}' with global index.", table.name()); + } + return result; } catch (IOException e) { throw new RuntimeException(e); }