accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject git commit: ACCUMULO-2082 Add in some better logging for the randomwalk Bulk tests.
Date Tue, 24 Dec 2013 00:59:55 GMT
Updated Branches:
  refs/heads/1.6.0-SNAPSHOT 3aace9806 -> 92bd40c6e


ACCUMULO-2082 Add in some better logging for the randomwalk Bulk tests.


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

Branch: refs/heads/1.6.0-SNAPSHOT
Commit: 92bd40c6ee5ce095321d5e876591874abc0b462e
Parents: 3aace98
Author: Josh Elser <elserj@apache.org>
Authored: Mon Dec 23 19:55:54 2013 -0500
Committer: Josh Elser <elserj@apache.org>
Committed: Mon Dec 23 19:55:54 2013 -0500

----------------------------------------------------------------------
 .../java/org/apache/accumulo/test/randomwalk/bulk/Compact.java | 6 ++++--
 .../java/org/apache/accumulo/test/randomwalk/bulk/Split.java   | 1 +
 2 files changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/92bd40c6/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Compact.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Compact.java b/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Compact.java
index fb2e23e..86dae5c 100644
--- a/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Compact.java
+++ b/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Compact.java
@@ -23,9 +23,11 @@ public class Compact extends BulkTest {
   
   @Override
   protected void runLater(State state) throws Exception {
-    Text[] points = Merge.getRandomTabletRange(state);
-    log.info("Compacting " + Merge.rangeToString(points));
+    final Text[] points = Merge.getRandomTabletRange(state);
+    final String rangeString = Merge.rangeToString(points);
+    log.info("Compacting " + rangeString);
     state.getConnector().tableOperations().compact(Setup.getTableName(), points[0], points[1],
false, true);
+    log.info("Compaction " + rangeString + " finished");
   }
   
 }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/92bd40c6/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Split.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Split.java b/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Split.java
index bbad74a..157e2ab 100644
--- a/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Split.java
+++ b/test/src/main/java/org/apache/accumulo/test/randomwalk/bulk/Split.java
@@ -34,6 +34,7 @@ public class Split extends BulkTest {
       splits.add(new Text(String.format(BulkPlusOne.FMT, (rand.nextLong() & 0x7fffffffffffffffl)
% BulkPlusOne.LOTS)));
     log.info("splitting " + splits);
     state.getConnector().tableOperations().addSplits(Setup.getTableName(), splits);
+    log.info("split for " + splits + " finished");
   }
   
 }


Mime
View raw message