accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [4/9] accumulo git commit: ACCUMULO-3879 Improved logging on MultiInstanceReplicationIT
Date Mon, 01 Jun 2015 19:40:58 GMT
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/master
Commit: a31ada5425c62a07195cf8148e60ed4735c1af57
Parents: c100231
Author: Josh Elser <elserj@apache.org>
Authored: Mon Jun 1 14:41:36 2015 -0400
Committer: Josh Elser <elserj@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);
     }


Mime
View raw message