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/11/26 05:23:30 UTC
[14/50] [abbrv] accumulo git commit: ACCUMULO-3167 Remove a pointless
stopAll
ACCUMULO-3167 Remove a pointless stopAll
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/e5cb8420
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/e5cb8420
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/e5cb8420
Branch: refs/heads/master
Commit: e5cb84204b2e3e84a8406f52fc321867815892db
Parents: 8f09ea1
Author: Josh Elser <el...@apache.org>
Authored: Sun Nov 23 19:42:53 2014 -0500
Committer: Josh Elser <el...@apache.org>
Committed: Mon Nov 24 18:08:52 2014 -0500
----------------------------------------------------------------------
.../test/functional/WriteAheadLogIT.java | 19 +++++++------------
1 file changed, 7 insertions(+), 12 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/e5cb8420/test/src/test/java/org/apache/accumulo/test/functional/WriteAheadLogIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/functional/WriteAheadLogIT.java b/test/src/test/java/org/apache/accumulo/test/functional/WriteAheadLogIT.java
index 261deb3..07218ad 100644
--- a/test/src/test/java/org/apache/accumulo/test/functional/WriteAheadLogIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/functional/WriteAheadLogIT.java
@@ -59,18 +59,13 @@ public class WriteAheadLogIT extends AccumuloClusterIT {
c.tableOperations().setProperty(tableName, Property.TABLE_SPLIT_THRESHOLD.getKey(), "750K");
TestIngest.Opts opts = new TestIngest.Opts();
opts.tableName = tableName;
- try {
- TestIngest.ingest(c, opts, new BatchWriterOpts());
- VerifyIngest.Opts vopts = new VerifyIngest.Opts();
- vopts.tableName = tableName;
- VerifyIngest.verifyIngest(c, vopts, new ScannerOpts());
- getCluster().getClusterControl().stopAllServers(ServerType.TABLET_SERVER);
- getCluster().getClusterControl().startAllServers(ServerType.TABLET_SERVER);
- VerifyIngest.verifyIngest(c, vopts, new ScannerOpts());
- getCluster().getClusterControl().adminStopAll();
- } finally {
- getCluster().start();
- }
+ TestIngest.ingest(c, opts, new BatchWriterOpts());
+ VerifyIngest.Opts vopts = new VerifyIngest.Opts();
+ vopts.tableName = tableName;
+ VerifyIngest.verifyIngest(c, vopts, new ScannerOpts());
+ getCluster().getClusterControl().stopAllServers(ServerType.TABLET_SERVER);
+ getCluster().getClusterControl().startAllServers(ServerType.TABLET_SERVER);
+ VerifyIngest.verifyIngest(c, vopts, new ScannerOpts());
}
}