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) {