You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by ya...@apache.org on 2026/09/15 10:32:44 UTC
(fluss) branch main updated: [server] Only log bucket-count backfill when partitions were backfilled
This is an automated email from the ASF dual-hosted git repository.
platinumhamburg 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 76345eb79 [server] Only log bucket-count backfill when partitions were backfilled
76345eb79 is described below
commit 76345eb79df83cfea07128817af1d02dec0b4a1b
Author: Kaixuan Duan <98...@users.noreply.github.com>
AuthorDate: Tue Sep 15 18:32:39 2026 +0800
[server] Only log bucket-count backfill when partitions were backfilled
---
.../java/org/apache/fluss/server/zk/ZooKeeperClient.java | 14 ++++++++------
1 file changed, 8 insertions(+), 6 deletions(-)
diff --git a/fluss-server/src/main/java/org/apache/fluss/server/zk/ZooKeeperClient.java b/fluss-server/src/main/java/org/apache/fluss/server/zk/ZooKeeperClient.java
index 010b2e840..2495a3b44 100644
--- a/fluss-server/src/main/java/org/apache/fluss/server/zk/ZooKeeperClient.java
+++ b/fluss-server/src/main/java/org/apache/fluss/server/zk/ZooKeeperClient.java
@@ -1178,12 +1178,14 @@ public class ZooKeeperClient implements AutoCloseable {
List<CuratorOp> fencedOps =
wrapRequestsWithEpochCheck(ops, expectedCoordinatorEpochZkVersion);
zkClient.transaction().forOperations(fencedOps);
- LOG.info(
- "Atomically backfilled bucket count for {} partition(s) and updated table {} in one "
- + "transaction (CAS + epoch fence {}).",
- partitionBackfills.size(),
- tablePath,
- expectedCoordinatorEpochZkVersion);
+ if (!partitionBackfills.isEmpty()) {
+ LOG.info(
+ "Atomically backfilled bucket count for {} partition(s) and updated table {} in "
+ + "one transaction (CAS + epoch fence {}).",
+ partitionBackfills.size(),
+ tablePath,
+ expectedCoordinatorEpochZkVersion);
+ }
}
/** Get partition id and table id for each partition in a batch async way. */