Updated Branches: refs/heads/master 2d8a2ecb8 -> 00bcb0cb0
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/master Commit: 92bd40c6ee5ce095321d5e876591874abc0b462e Parents: 3aace98 Author: Josh Elser <els...@apache.org> Authored: Mon Dec 23 19:55:54 2013 -0500 Committer: Josh Elser <els...@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"); } }
