This is an automated email from the ASF dual-hosted git repository.
zhaijia 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 1f0d153 ISSUE #988: more log lines for replication status changes
1f0d153 is described below
commit 1f0d15356ef10c8ebb14dfb3048b66dbec6c0260
Author: cguttapalem <[email protected]>
AuthorDate: Wed Jan 17 23:07:10 2018 +0800
ISSUE #988: more log lines for replication status changes
Descriptions of the changes in this PR:
more log lines for replication status changes
Master Issue: #988
Author: cguttapalem <[email protected]>
Reviewers: Enrico Olivelli <[email protected]>, Jia Zhai <None>, Sijie
Guo <[email protected]>
This closes #989 from reddycharan/replicatorlogs, closes #988
---
.../org/apache/bookkeeper/meta/ZkLedgerUnderreplicationManager.java | 4 ++++
.../src/main/java/org/apache/bookkeeper/replication/Auditor.java | 2 ++
2 files changed, 6 insertions(+)
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 35b76d5..3fa0daf 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
@@ -672,6 +672,8 @@ public class ZkLedgerUnderreplicationManager implements
LedgerUnderreplicationMa
Watcher w = new Watcher() {
public void process(WatchedEvent e) {
if (e.getType() == Watcher.Event.EventType.NodeDeleted) {
+ LOG.info("LedgerReplication is enabled externally through
Zookeeper, "
+ + "since DISABLE_NODE ZNode is deleted");
cb.operationComplete(0, null);
}
}
@@ -679,6 +681,8 @@ public class ZkLedgerUnderreplicationManager implements
LedgerUnderreplicationMa
try {
if (null == zkc.exists(basePath + '/'
+ BookKeeperConstants.DISABLE_NODE, w)) {
+ LOG.info("LedgerReplication is enabled externally through
Zookeeper, "
+ + "since DISABLE_NODE ZNode is deleted");
cb.operationComplete(0, null);
return;
}
diff --git
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java
index 453afdc..188ce71 100644
---
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java
+++
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java
@@ -419,6 +419,8 @@ public class Auditor {
InterruptedException {
ReplicationEnableCb cb = new ReplicationEnableCb();
if (!ledgerUnderreplicationManager.isLedgerReplicationEnabled()) {
+ LOG.info("LedgerReplication is disabled externally through
Zookeeper, "
+ + "since DISABLE_NODE ZNode is created, so waiting untill
it is enabled");
ledgerUnderreplicationManager.notifyLedgerReplicationEnabled(cb);
cb.await();
}
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
