You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by iv...@apache.org on 2013/08/20 13:03:00 UTC
svn commit: r1515774 - in /zookeeper/bookkeeper/trunk: CHANGES.txt
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationWorker.java
Author: ivank
Date: Tue Aug 20 11:02:59 2013
New Revision: 1515774
URL: http://svn.apache.org/r1515774
Log:
BOOKKEEPER-624: Reduce logs generated by ReplicationWorker (vinay via ivank)
Modified:
zookeeper/bookkeeper/trunk/CHANGES.txt
zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationWorker.java
Modified: zookeeper/bookkeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/CHANGES.txt?rev=1515774&r1=1515773&r2=1515774&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/CHANGES.txt (original)
+++ zookeeper/bookkeeper/trunk/CHANGES.txt Tue Aug 20 11:02:59 2013
@@ -90,6 +90,8 @@ Trunk (unreleased changes)
BOOKKEEPER-668: Race between PerChannelBookieClient#channelDisconnected() and disconnect() calls can make clients hang while add/reading entries in case of multiple bookie failures (sijie & ivank via ivank)
+ BOOKKEEPER-624: Reduce logs generated by ReplicationWorker (vinay via ivank)
+
hedwig-server:
BOOKKEEPER-601: readahead cache size isn't updated correctly (sijie via fpj)
Modified: zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationWorker.java
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationWorker.java?rev=1515774&r1=1515773&r2=1515774&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationWorker.java (original)
+++ zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationWorker.java Tue Aug 20 11:02:59 2013
@@ -138,8 +138,7 @@ public class ReplicationWorker implement
UnavailableException {
long ledgerIdToReplicate = underreplicationManager
.getLedgerToRereplicate();
- LOG.info("Going to replicate the fragments of the ledger: "
- + ledgerIdToReplicate);
+ LOG.debug("Going to replicate the fragments of the ledger: {}", ledgerIdToReplicate);
LedgerHandle lh;
try {
lh = admin.openLedgerNoRecovery(ledgerIdToReplicate);
@@ -169,8 +168,7 @@ public class ReplicationWorker implement
return;
}
Set<LedgerFragment> fragments = getUnderreplicatedFragments(lh);
- LOG.info("Founds fragments " + fragments
- + " for replication from ledger: " + ledgerIdToReplicate);
+ LOG.debug("Founds fragments {} for replication from ledger: {}", fragments, ledgerIdToReplicate);
boolean foundOpenFragments = false;
for (LedgerFragment ledgerFragment : fragments) {
@@ -179,9 +177,8 @@ public class ReplicationWorker implement
continue;
} else if (isTargetBookieExistsInFragmentEnsemble(lh,
ledgerFragment)) {
- LOG.info("Target Bookie[" + targetBookie
- + "] found in the fragment ensemble:"
- + ledgerFragment.getEnsemble());
+ LOG.debug("Target Bookie[{}] found in the fragment ensemble: {}", targetBookie,
+ ledgerFragment.getEnsemble());
continue;
}
try {