accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject accumulo git commit: ACCUMULO-4124 run sub-jobs in local mode
Date Tue, 02 Feb 2016 20:27:40 GMT
Repository: accumulo
Updated Branches:
  refs/heads/master 7be2f04e5 -> b4cd908a3


ACCUMULO-4124 run sub-jobs in local mode


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b4cd908a
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b4cd908a
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b4cd908a

Branch: refs/heads/master
Commit: b4cd908a3cef731b0d7154b94097c7ce0eea4e09
Parents: 7be2f04
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Tue Feb 2 15:27:30 2016 -0500
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Tue Feb 2 15:27:30 2016 -0500

----------------------------------------------------------------------
 .../accumulo/test/examples/simple/filedata/ChunkInputFormatIT.java  | 1 +
 .../org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java | 1 +
 .../java/org/apache/accumulo/test/mapred/AccumuloInputFormatIT.java | 1 +
 .../accumulo/test/mapred/AccumuloMultiTableInputFormatIT.java       | 1 +
 .../org/apache/accumulo/test/mapred/AccumuloOutputFormatIT.java     | 1 +
 .../org/apache/accumulo/test/mapred/AccumuloRowInputFormatIT.java   | 1 +
 test/src/main/java/org/apache/accumulo/test/mapred/TokenFileIT.java | 1 +
 .../apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java  | 1 +
 .../org/apache/accumulo/test/mapreduce/AccumuloInputFormatIT.java   | 1 +
 .../accumulo/test/mapreduce/AccumuloMultiTableInputFormatIT.java    | 1 +
 .../org/apache/accumulo/test/mapreduce/AccumuloOutputFormatIT.java  | 1 +
 .../apache/accumulo/test/mapreduce/AccumuloRowInputFormatIT.java    | 1 +
 .../main/java/org/apache/accumulo/test/mapreduce/TokenFileIT.java   | 1 +
 13 files changed, 13 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/examples/simple/filedata/ChunkInputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/examples/simple/filedata/ChunkInputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/examples/simple/filedata/ChunkInputFormatIT.java
index b2b6aff..69d30af 100644
--- a/test/src/main/java/org/apache/accumulo/test/examples/simple/filedata/ChunkInputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/examples/simple/filedata/ChunkInputFormatIT.java
@@ -260,6 +260,7 @@ public class ChunkInputFormatIT extends AccumuloClusterHarness {
 
     public static int main(String... args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       return ToolRunner.run(conf, new CIFTester(), args);
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
index dd085cc..fda3713 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
@@ -166,6 +166,7 @@ public class AccumuloFileOutputFormatIT extends AccumuloClusterHarness
{
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloInputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloInputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloInputFormatIT.java
index cd80139..2a15041 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloInputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloInputFormatIT.java
@@ -142,6 +142,7 @@ public class AccumuloInputFormatIT extends AccumuloClusterHarness {
 
     public static void main(String... args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloMultiTableInputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloMultiTableInputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloMultiTableInputFormatIT.java
index 35ba7bc..fb3177a 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloMultiTableInputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloMultiTableInputFormatIT.java
@@ -129,6 +129,7 @@ public class AccumuloMultiTableInputFormatIT extends AccumuloClusterHarness
{
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloOutputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloOutputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloOutputFormatIT.java
index bb48761..049a5da 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloOutputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloOutputFormatIT.java
@@ -192,6 +192,7 @@ public class AccumuloOutputFormatIT extends ConfigurableMacBase {
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloRowInputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloRowInputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloRowInputFormatIT.java
index d266d3d..98978dc 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloRowInputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloRowInputFormatIT.java
@@ -174,6 +174,7 @@ public class AccumuloRowInputFormatIT extends AccumuloClusterHarness {
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapred/TokenFileIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapred/TokenFileIT.java b/test/src/main/java/org/apache/accumulo/test/mapred/TokenFileIT.java
index e30a033..78fc76d 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapred/TokenFileIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapred/TokenFileIT.java
@@ -131,6 +131,7 @@ public class TokenFileIT extends AccumuloClusterHarness {
     public static void main(String[] args) throws Exception {
       Configuration conf = CachedConfiguration.getInstance();
       conf.set("hadoop.tmp.dir", new File(args[0]).getParent());
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTokenFileTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
index d00a9b3..883a657 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
@@ -180,6 +180,7 @@ public class AccumuloFileOutputFormatIT extends AccumuloClusterHarness
{
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloInputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloInputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloInputFormatIT.java
index 0a5bd68..a094149 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloInputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloInputFormatIT.java
@@ -320,6 +320,7 @@ public class AccumuloInputFormatIT extends AccumuloClusterHarness {
 
     public static int main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       return ToolRunner.run(conf, new MRTester(), args);
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloMultiTableInputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloMultiTableInputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloMultiTableInputFormatIT.java
index 1694f6b..bd7ea42 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloMultiTableInputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloMultiTableInputFormatIT.java
@@ -124,6 +124,7 @@ public class AccumuloMultiTableInputFormatIT extends AccumuloClusterHarness
{
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloOutputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloOutputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloOutputFormatIT.java
index c9307ae..811f3fe 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloOutputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloOutputFormatIT.java
@@ -119,6 +119,7 @@ public class AccumuloOutputFormatIT extends AccumuloClusterHarness {
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloRowInputFormatIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloRowInputFormatIT.java
b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloRowInputFormatIT.java
index 617a8c2..1275bf9 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloRowInputFormatIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloRowInputFormatIT.java
@@ -169,6 +169,7 @@ public class AccumuloRowInputFormatIT extends AccumuloClusterHarness {
 
     public static void main(String[] args) throws Exception {
       Configuration conf = new Configuration();
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTester(), args));
     }

http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4cd908a/test/src/main/java/org/apache/accumulo/test/mapreduce/TokenFileIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mapreduce/TokenFileIT.java b/test/src/main/java/org/apache/accumulo/test/mapreduce/TokenFileIT.java
index f5deebb..6c3b9ef 100644
--- a/test/src/main/java/org/apache/accumulo/test/mapreduce/TokenFileIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/mapreduce/TokenFileIT.java
@@ -124,6 +124,7 @@ public class TokenFileIT extends AccumuloClusterHarness {
     public static void main(String[] args) throws Exception {
       Configuration conf = CachedConfiguration.getInstance();
       conf.set("hadoop.tmp.dir", new File(args[0]).getParent());
+      conf.set("mapreduce.framework.name", "local");
       conf.set("mapreduce.cluster.local.dir", new File(System.getProperty("user.dir"), "target/mapreduce-tmp").getAbsolutePath());
       assertEquals(0, ToolRunner.run(conf, new MRTokenFileTester(), args));
     }


Mime
View raw message