You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by ch...@apache.org on 2022/07/27 11:09:13 UTC
[bookkeeper] branch master updated: Pre break loop when self create layoutZNode succeed. (#3335)
This is an automated email from the ASF dual-hosted git repository.
chenhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
The following commit(s) were added to refs/heads/master by this push:
new ca7d7c23e3 Pre break loop when self create layoutZNode succeed. (#3335)
ca7d7c23e3 is described below
commit ca7d7c23e3aa572befeb447157b3ef9d96bb1449
Author: Yan Zhao <ho...@apache.org>
AuthorDate: Wed Jul 27 19:09:07 2022 +0800
Pre break loop when self create layoutZNode succeed. (#3335)
Pre break loop when self create layoutZNode succeed.
---
.../org/apache/bookkeeper/meta/ZkLedgerUnderreplicationManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerUnderreplicationManager.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerUnderreplicationManager.java
index 097b877ac0..3ac346b1cc 100644
--- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerUnderreplicationManager.java
+++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerUnderreplicationManager.java
@@ -192,9 +192,9 @@ public class ZkLedgerUnderreplicationManager implements LedgerUnderreplicationMa
try {
zkc.create(layoutZNode, builder.build().toString().getBytes(UTF_8),
zkAcls, CreateMode.PERSISTENT);
+ break;
} catch (KeeperException.NodeExistsException nne) {
// someone else managed to create it
- continue;
}
} else {
byte[] layoutData = zkc.getData(layoutZNode, false, null);