Skip to content

Commit 2ab3ce2

Browse files
authored
[server] print snapshot size in snapshot finish log (#2516)
1 parent 62ada45 commit 2ab3ce2

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/PeriodicSnapshotManager.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -244,9 +244,11 @@ private void asyncSnapshotPhase(
244244
snapshotLocation,
245245
snapshotResult);
246246
LOG.info(
247-
"TableBucket {} snapshot {} finished successfully, cost {} ms.",
247+
"TableBucket {} snapshot {} finished successfully, full size: {}, incremental size: {}, cost: {} ms.",
248248
tableBucket,
249249
snapshotId,
250+
snapshotResult.getSnapshotSize(),
251+
snapshotResult.getIncrementalSize(),
250252
System.currentTimeMillis() - triggerTime);
251253
} catch (Throwable t) {
252254
LOG.warn(

fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/SnapshotResult.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,4 +56,8 @@ public long getLogOffset() {
5656
public long getSnapshotSize() {
5757
return kvSnapshotHandle.getSnapshotSize();
5858
}
59+
60+
public long getIncrementalSize() {
61+
return kvSnapshotHandle.getIncrementalSize();
62+
}
5963
}

0 commit comments

Comments
 (0)