You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/06/14 06:55:04 UTC
[04/51] [abbrv] git commit: ACCUMULO-378 Tone back logging into
something a bit more useful for FinishedWorkUpdater.
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 <el...@apache.org>
Authored: Tue May 27 16:29:25 2014 -0400
Committer: Josh Elser <el...@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