You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/07/11 22:07:35 UTC

svn commit: r1502343 - in /accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional: DeleteIT.java MacTest.java SplitIT.java

Author: ecn
Date: Thu Jul 11 20:07:34 2013
New Revision: 1502343

URL: http://svn.apache.org/r1502343
Log:
ACCUMULO-1537 fix static cluster/folder in MacTest

Modified:
    accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/DeleteIT.java
    accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MacTest.java
    accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/SplitIT.java

Modified: accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/DeleteIT.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/DeleteIT.java?rev=1502343&r1=1502342&r2=1502343&view=diff
==============================================================================
--- accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/DeleteIT.java (original)
+++ accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/DeleteIT.java Thu Jul 11 20:07:34 2013
@@ -20,6 +20,7 @@ import static org.junit.Assert.assertEqu
 
 import org.apache.accumulo.core.cli.ScannerOpts;
 import org.apache.accumulo.core.client.Connector;
+import org.apache.accumulo.minicluster.MiniAccumuloCluster;
 import org.apache.accumulo.server.util.Admin;
 import org.apache.accumulo.test.TestIngest;
 import org.apache.accumulo.test.TestRandomDeletes;
@@ -32,11 +33,11 @@ public class DeleteIT extends MacTest {
   public void test() throws Exception {
     Connector c = getConnector();
     c.tableOperations().create("test_ingest");
-    deleteTest(c);
+    deleteTest(c, cluster);
     assertEquals(0, cluster.exec(Admin.class, "stopAll").waitFor());
   }
 
-  public static void deleteTest(Connector c) throws Exception {
+  public static void deleteTest(Connector c, MiniAccumuloCluster cluster) throws Exception {
     VerifyIngest.Opts vopts = new VerifyIngest.Opts();
     TestIngest.Opts opts = new TestIngest.Opts();
     vopts.rows = opts.rows = 1000;

Modified: accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MacTest.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MacTest.java?rev=1502343&r1=1502342&r2=1502343&view=diff
==============================================================================
--- accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MacTest.java (original)
+++ accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MacTest.java Thu Jul 11 20:07:34 2013
@@ -31,11 +31,11 @@ import org.junit.rules.TemporaryFolder;
 
 public class MacTest {
   public static final Logger log = Logger.getLogger(MacTest.class);
-  public static TemporaryFolder folder = new TemporaryFolder();
-  public static MiniAccumuloCluster cluster;
   public static final String PASSWORD = "secret";
   static final ScannerOpts SOPTS = new ScannerOpts();
   static final BatchWriterOpts BWOPTS = new BatchWriterOpts();
+  public TemporaryFolder folder = new TemporaryFolder();
+  public MiniAccumuloCluster cluster;
   
   public Connector getConnector() throws AccumuloException, AccumuloSecurityException {
     return cluster.getConnector("root", PASSWORD);

Modified: accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/SplitIT.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/SplitIT.java?rev=1502343&r1=1502342&r2=1502343&view=diff
==============================================================================
--- accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/SplitIT.java (original)
+++ accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/SplitIT.java Thu Jul 11 20:07:34 2013
@@ -101,7 +101,7 @@ public class SplitIT extends MacTest {
     Connector c = getConnector();
     c.tableOperations().create("test_ingest");
     c.tableOperations().setProperty("test_ingest", Property.TABLE_SPLIT_THRESHOLD.getKey(), "10K");
-    DeleteIT.deleteTest(c);
+    DeleteIT.deleteTest(c, cluster);
     c.tableOperations().flush("test_ingest", null, null, true);
     UtilWaitThread.sleep(10*1000);
     assertTrue(c.tableOperations().listSplits("test_ingest").size() > 30);