(paimon) branch master updated: [core] Log when scan uses global index (#7977)

[junhao]

This is an automated email from the ASF dual-hosted git repository.

leaves12138 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new e50543aae3 [core] Log when scan uses global index (#7977)
e50543aae3 is described below

commit e50543aae346603d75c1e7d2c3b41b824ed792a7
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Tue May 26 17:41:54 2026 +0800

    [core] Log when scan uses global index (#7977)
---
 .../org/apache/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 51fa3520d7..8d6038ccc4 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.Filter;
 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 @@ import static 
org.apache.paimon.utils.ManifestReadThreadPool.randomlyExecuteSequ
 /** 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 @@ public class DataEvolutionBatchScan implements 
DataTableScan {
         }
 
         try (GlobalIndexScanner scanner = optionalScanner.get()) {
-            return scanner.scan(filter);
+            Optional<GlobalIndexResult> 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);
         }