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 2015/06/01 21:40:57 UTC
[3/9] accumulo git commit: ACCUMULO-3879 Improved logging on
MultiInstanceReplicationIT
ACCUMULO-3879 Improved logging on MultiInstanceReplicationIT
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a31ada54
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a31ada54
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a31ada54
Branch: refs/heads/1.7
Commit: a31ada5425c62a07195cf8148e60ed4735c1af57
Parents: c100231
Author: Josh Elser <el...@apache.org>
Authored: Mon Jun 1 14:41:36 2015 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Mon Jun 1 14:44:20 2015 -0400
----------------------------------------------------------------------
.../accumulo/test/replication/MultiInstanceReplicationIT.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/a31ada54/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java b/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
index 7dd31c0..3dc029e 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/MultiInstanceReplicationIT.java
@@ -216,6 +216,8 @@ public class MultiInstanceReplicationIT extends ConfigurableMacIT {
final Set<String> filesNeedingReplication = connMaster.replicationOperations().referencedFiles(masterTable);
+ log.info("Files to replicate: " + filesNeedingReplication);
+
for (ProcessReference proc : cluster.getProcesses().get(ServerType.TABLET_SERVER)) {
cluster.killProcess(ServerType.TABLET_SERVER, proc);
}
@@ -403,6 +405,9 @@ public class MultiInstanceReplicationIT extends ConfigurableMacIT {
Set<String> filesFor1 = connMaster.replicationOperations().referencedFiles(masterTable1), filesFor2 = connMaster.replicationOperations().referencedFiles(
masterTable2);
+ log.info("Files to replicate for table1: " + filesFor1);
+ log.info("Files to replicate for table2: " + filesFor2);
+
// Restart the tserver to force a close on the WAL
for (ProcessReference proc : cluster.getProcesses().get(ServerType.TABLET_SERVER)) {
cluster.killProcess(ServerType.TABLET_SERVER, proc);
@@ -520,6 +525,8 @@ public class MultiInstanceReplicationIT extends ConfigurableMacIT {
Set<String> files = connMaster.replicationOperations().referencedFiles(masterTable);
+ log.info("Files to replicate:" + files);
+
for (ProcessReference proc : cluster.getProcesses().get(ServerType.TABLET_SERVER)) {
cluster.killProcess(ServerType.TABLET_SERVER, proc);
}