accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [04/51] [abbrv] git commit: ACCUMULO-378 Tone back logging into something a bit more useful for FinishedWorkUpdater.
Date Sat, 14 Jun 2014 04:55:04 GMT
ACCUMULO-378 Tone back logging into something a bit more useful for FinishedWorkUpdater.


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/177eabff
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/177eabff
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/177eabff

Branch: refs/heads/master
Commit: 177eabff7c4e93b0df069a2941c3053a80365b9c
Parents: f275353
Author: Josh Elser <elserj@apache.org>
Authored: Tue May 27 16:29:25 2014 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Tue May 27 16:29:25 2014 -0400

----------------------------------------------------------------------
 .../accumulo/master/replication/FinishedWorkUpdater.java       | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/177eabff/server/master/src/main/java/org/apache/accumulo/master/replication/FinishedWorkUpdater.java
----------------------------------------------------------------------
diff --git a/server/master/src/main/java/org/apache/accumulo/master/replication/FinishedWorkUpdater.java
b/server/master/src/main/java/org/apache/accumulo/master/replication/FinishedWorkUpdater.java
index 3f26af9..8048e02 100644
--- a/server/master/src/main/java/org/apache/accumulo/master/replication/FinishedWorkUpdater.java
+++ b/server/master/src/main/java/org/apache/accumulo/master/replication/FinishedWorkUpdater.java
@@ -124,10 +124,6 @@ public class FinishedWorkUpdater implements Runnable {
           tableIdToProgress.put(target.getSourceTableId(), Math.min(tableIdToProgress.get(target.getSourceTableId()),
status.getBegin()));
         } 
 
-        for (Entry<String,Long> progressByTable : tableIdToProgress.entrySet()) {
-          log.debug("For {}, source table ID {} has replicated through {}", serializedRow.getKey().getRow(),
progressByTable.getKey(), progressByTable.getValue());
-        }
-
         if (error) {
           continue;
         }
@@ -141,6 +137,8 @@ public class FinishedWorkUpdater implements Runnable {
 
           serializedRow.getKey().getRow(buffer);
 
+          log.debug("For {}, source table ID {} has replicated through {}", serializedRow.getKey().getRow(),
entry.getKey(), entry.getValue());
+
           Mutation replMutation = new Mutation(buffer);
 
           // Set that we replicated at least this much data, ignoring the other fields


Mime
View raw message