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

biyan 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 49f485a5b0 [spark] Add latestSnapshotId to the description in paimon 
scan (#6308)
49f485a5b0 is described below

commit 49f485a5b069282a3417c3eee2a9703733370049
Author: Kerwin Zhang <[email protected]>
AuthorDate: Tue Sep 23 22:26:20 2025 +0800

    [spark] Add latestSnapshotId to the description in paimon scan (#6308)
---
 .../src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala
 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala
index a2d7ac05a5..eff44cdfce 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala
+++ 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala
@@ -132,7 +132,12 @@ abstract class PaimonBaseScan(
     } else {
       ""
     }
-    s"PaimonScan: [${table.name}]" + pushedFiltersStr + pushedTopNFilterStr +
+    val latestSnapshotIdStr = if (table.latestSnapshot().isPresent) {
+      s", LatestSnapshotId: [${table.latestSnapshot().get.id}],"
+    } else {
+      ""
+    }
+    s"PaimonScan: [${table.name}]" + latestSnapshotIdStr + pushedFiltersStr + 
pushedTopNFilterStr +
       pushDownLimit.map(limit => s", Limit: [$limit]").getOrElse("")
   }
 }

Reply via email to