(fluss) branch main updated: [server] print snapshot size in snapshot finish log (#2516)

[jark]

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

jark pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 2ab3ce215 [server] print snapshot size in snapshot finish log (#2516)
2ab3ce215 is described below

commit 2ab3ce2151eb9f2ded6594709b396a8865126477
Author: Junfan Zhang <zus...@apache.org>
AuthorDate: Thu Feb 5 13:56:13 2026 +0800

    [server] print snapshot size in snapshot finish log (#2516)
---
 .../org/apache/fluss/server/kv/snapshot/PeriodicSnapshotManager.java  | 4 +++-
 .../main/java/org/apache/fluss/server/kv/snapshot/SnapshotResult.java | 4 ++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/PeriodicSnapshotManager.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/PeriodicSnapshotManager.java
index c6b42f0ef..9ba9ecbd6 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/PeriodicSnapshotManager.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/PeriodicSnapshotManager.java
@@ -244,9 +244,11 @@ public class PeriodicSnapshotManager implements Closeable {
                                             snapshotLocation,
                                             snapshotResult);
                                     LOG.info(
-                                            "TableBucket {} snapshot {} 
finished successfully, cost {} ms.",
+                                            "TableBucket {} snapshot {} 
finished successfully, full size: {}, incremental size: {}, cost: {} ms.",
                                             tableBucket,
                                             snapshotId,
+                                            snapshotResult.getSnapshotSize(),
+                                            
snapshotResult.getIncrementalSize(),
                                             System.currentTimeMillis() - 
triggerTime);
                                 } catch (Throwable t) {
                                     LOG.warn(
diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/SnapshotResult.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/SnapshotResult.java
index 1071b9acd..13d1e75aa 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/SnapshotResult.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/SnapshotResult.java
@@ -56,4 +56,8 @@ public class SnapshotResult implements Serializable {
     public long getSnapshotSize() {
         return kvSnapshotHandle.getSnapshotSize();
     }
+
+    public long getIncrementalSize() {
+        return kvSnapshotHandle.getIncrementalSize();
+    }
 }