hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e...@apache.org
Subject svn commit: r1524209 - /hbase/branches/0.96/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
Date Tue, 17 Sep 2013 20:20:32 GMT
Author: enis
Date: Tue Sep 17 20:20:32 2013
New Revision: 1524209

URL: http://svn.apache.org/r1524209
Log:
HBASE-9550 IntegrationTestBigLinkedList used to be able to run on pseudo-distributed clusters

Modified:
    hbase/branches/0.96/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java

Modified: hbase/branches/0.96/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java?rev=1524209&r1=1524208&r2=1524209&view=diff
==============================================================================
--- hbase/branches/0.96/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
(original)
+++ hbase/branches/0.96/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
Tue Sep 17 20:20:32 2013
@@ -28,7 +28,6 @@ import java.util.Random;
 import java.util.Set;
 import java.util.UUID;
 
-import com.google.common.collect.Sets;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.GnuParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -87,6 +86,8 @@ import org.junit.Before;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
+import com.google.common.collect.Sets;
+
 /**
  * This is an integration test borrowed from goraci, written by Keith Turner,
  * which is in turn inspired by the Accumulo test called continous ingest (ci).
@@ -331,6 +332,7 @@ public class IntegrationTestBigLinkedLis
       long wrap;
       int width;
 
+      @Override
       protected void setup(Context context) throws IOException, InterruptedException {
         id = Bytes.toBytes(UUID.randomUUID().toString());
         Configuration conf = context.getConfiguration();
@@ -348,6 +350,7 @@ public class IntegrationTestBigLinkedLis
         }
       }
 
+      @Override
       protected void cleanup(Context context) throws IOException ,InterruptedException {
         table.close();
       }
@@ -547,6 +550,7 @@ public class IntegrationTestBigLinkedLis
     public static class VerifyReducer extends Reducer<BytesWritable,BytesWritable,Text,Text>
{
       private ArrayList<byte[]> refs = new ArrayList<byte[]>();
 
+      @Override
       public void reduce(BytesWritable key, Iterable<BytesWritable> values, Context
context)
           throws IOException, InterruptedException {
 
@@ -768,6 +772,7 @@ public class IntegrationTestBigLinkedLis
    * A stand alone program that prints out portions of a list created by {@link Generator}
    */
   private static class Print extends Configured implements Tool {
+    @Override
     public int run(String[] args) throws Exception {
       Options options = new Options();
       options.addOption("s", "start", true, "start key");
@@ -828,6 +833,7 @@ public class IntegrationTestBigLinkedLis
    * A stand alone program that deletes a single node.
    */
   private static class Delete extends Configured implements Tool {
+    @Override
     public int run(String[] args) throws Exception {
       if (args.length != 1) {
         System.out.println("Usage : " + Delete.class.getSimpleName() + " <node to delete>");
@@ -853,6 +859,7 @@ public class IntegrationTestBigLinkedLis
    * A stand alone program that follows a linked list created by {@link Generator} and prints
timing info.
    */
   private static class Walker extends Configured implements Tool {
+    @Override
     public int run(String[] args) throws IOException {
       Options options = new Options();
       options.addOption("n", "num", true, "number of queries");
@@ -980,7 +987,7 @@ public class IntegrationTestBigLinkedLis
   @Override
   public void setUp() throws Exception {
     util = getTestingUtil(getConf());
-    util.initializeCluster(this.NUM_SLAVES_BASE);
+    util.initializeCluster(util.isDistributedCluster() ? 1 : this.NUM_SLAVES_BASE);
     this.setConf(util.getConfiguration());
   }
 



Mime
View raw message