From df4f4790c82e0f9a25be7ee160ea6f711a14f14f Mon Sep 17 00:00:00 2001 From: Junbo Wang Date: Mon, 20 Jul 2026 14:08:55 +0800 Subject: [PATCH] [tiering] Reduce LakeSnapshot log verbosity in TieringSplitGenerator --- .../flink/tiering/source/split/TieringSplitGenerator.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/split/TieringSplitGenerator.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/split/TieringSplitGenerator.java index 1bb94a7a92..a4b2638f30 100644 --- a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/split/TieringSplitGenerator.java +++ b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/split/TieringSplitGenerator.java @@ -65,7 +65,11 @@ public List generateTableSplits(TableInfo tableInfo) throws Except LakeSnapshot lakeSnapshotInfo; try { lakeSnapshotInfo = flussAdmin.getLatestLakeSnapshot(tableInfo.getTablePath()).get(); - LOG.info("Last committed lake table snapshot info is:{}", lakeSnapshotInfo); + LOG.info( + "Last committed lake table snapshot: snapshotId={}, numBucketOffsets={}", + lakeSnapshotInfo.getSnapshotId(), + lakeSnapshotInfo.getTableBucketsOffset().size()); + LOG.debug("Last committed lake table snapshot detail: {}", lakeSnapshotInfo); } catch (Exception e) { Throwable t = ExceptionUtils.stripExecutionException(e); if (t instanceof LakeTableSnapshotNotExistException) {