accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ctubb...@apache.org
Subject svn commit: r1500063 - in /accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional: BigRootTabletIT.java MetadataMaxFiles.java
Date Fri, 05 Jul 2013 16:33:07 GMT
Author: ctubbsii
Date: Fri Jul  5 16:33:07 2013
New Revision: 1500063

URL: http://svn.apache.org/r1500063
Log:
ACCUMULO-1537 fix compile error

Modified:
    accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/BigRootTabletIT.java
    accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MetadataMaxFiles.java

Modified: accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/BigRootTabletIT.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/BigRootTabletIT.java?rev=1500063&r1=1500062&r2=1500063&view=diff
==============================================================================
--- accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/BigRootTabletIT.java
(original)
+++ accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/BigRootTabletIT.java
Fri Jul  5 16:33:07 2013
@@ -16,7 +16,7 @@
  */
 package org.apache.accumulo.test.functional;
 
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertTrue;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -26,9 +26,9 @@ import org.apache.accumulo.core.client.C
 import org.apache.accumulo.core.conf.Property;
 import org.apache.accumulo.core.data.Key;
 import org.apache.accumulo.core.data.Value;
+import org.apache.accumulo.core.metadata.MetadataTable;
+import org.apache.accumulo.core.metadata.RootTable;
 import org.apache.accumulo.core.security.Authorizations;
-import org.apache.accumulo.core.util.MetadataTable;
-import org.apache.accumulo.core.util.RootTable;
 import org.apache.accumulo.minicluster.MiniAccumuloConfig;
 import org.junit.Test;
 
@@ -37,13 +37,13 @@ public class BigRootTabletIT extends Mac
   
   @Override
   public void configure(MiniAccumuloConfig cfg) {
-    Map<String,String> siteConfig = new HashMap<String, String>();
+    Map<String,String> siteConfig = new HashMap<String,String>();
     siteConfig.put(Property.TABLE_SCAN_MAXMEM.getKey(), "1024");
     siteConfig.put(Property.TSERV_MAJC_DELAY.getKey(), "60m");
-    cfg.setSiteConfig(siteConfig );
+    cfg.setSiteConfig(siteConfig);
   }
-
-  @Test(timeout=60*1000)
+  
+  @Test(timeout = 60 * 1000)
   public void test() throws Exception {
     Connector c = getConnector();
     c.tableOperations().addSplits(MetadataTable.NAME, FunctionalTestUtils.splits("0 1 2 3
4 5 6 7 8 9 a".split(" ")));
@@ -55,7 +55,8 @@ public class BigRootTabletIT extends Mac
     cluster.stop();
     cluster.start();
     int count = 0;
-    for (@SuppressWarnings("unused") Entry<Key,Value> entry : c.createScanner(RootTable.NAME,
Authorizations.EMPTY))
+    for (@SuppressWarnings("unused")
+    Entry<Key,Value> entry : c.createScanner(RootTable.NAME, Authorizations.EMPTY))
       count++;
     assertTrue(count > 0);
   }

Modified: accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MetadataMaxFiles.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MetadataMaxFiles.java?rev=1500063&r1=1500062&r2=1500063&view=diff
==============================================================================
--- accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MetadataMaxFiles.java
(original)
+++ accumulo/trunk/test/src/test/java/org/apache/accumulo/test/functional/MetadataMaxFiles.java
Fri Jul  5 16:33:07 2013
@@ -16,7 +16,7 @@
  */
 package org.apache.accumulo.test.functional;
 
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertEquals;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -32,10 +32,10 @@ import org.apache.accumulo.core.master.t
 import org.apache.accumulo.core.master.thrift.MasterMonitorInfo;
 import org.apache.accumulo.core.master.thrift.TableInfo;
 import org.apache.accumulo.core.master.thrift.TabletServerStatus;
+import org.apache.accumulo.core.metadata.MetadataTable;
+import org.apache.accumulo.core.metadata.RootTable;
 import org.apache.accumulo.core.security.CredentialHelper;
 import org.apache.accumulo.core.security.thrift.TCredentials;
-import org.apache.accumulo.core.util.MetadataTable;
-import org.apache.accumulo.core.util.RootTable;
 import org.apache.accumulo.core.util.UtilWaitThread;
 import org.apache.accumulo.minicluster.MiniAccumuloConfig;
 import org.apache.accumulo.server.util.Admin;
@@ -47,13 +47,13 @@ public class MetadataMaxFiles extends Ma
   
   @Override
   public void configure(MiniAccumuloConfig cfg) {
-    Map<String,String> siteConfig = new HashMap<String, String>();
+    Map<String,String> siteConfig = new HashMap<String,String>();
     siteConfig.put(Property.TSERV_MAJC_DELAY.getKey(), "1");
     siteConfig.put(Property.TSERV_SCAN_MAX_OPENFILES.getKey(), "10");
-    cfg.setSiteConfig(siteConfig );
+    cfg.setSiteConfig(siteConfig);
   }
-
-  @Test(timeout=240*1000)
+  
+  @Test(timeout = 240 * 1000)
   public void test() throws Exception {
     Connector c = getConnector();
     SortedSet<Text> splits = new TreeSet<Text>();
@@ -71,15 +71,15 @@ public class MetadataMaxFiles extends Ma
       c.tableOperations().flush(MetadataTable.NAME, null, null, true);
       c.tableOperations().flush(RootTable.NAME, null, null, true);
     }
-    UtilWaitThread.sleep(20*1000);
+    UtilWaitThread.sleep(20 * 1000);
     log.info("shutting down");
     assertEquals(0, cluster.exec(Admin.class, "stopAll").waitFor());
     cluster.stop();
     log.info("starting up");
     cluster.start();
-
-    UtilWaitThread.sleep(30*1000);
-
+    
+    UtilWaitThread.sleep(30 * 1000);
+    
     while (true) {
       MasterMonitorInfo stats = null;
       TCredentials creds = CredentialHelper.create("root", new PasswordToken(MacTest.PASSWORD),
c.getInstance().getInstanceName());



Mime
View raw message