incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/3] git commit: Fixing broken tests.
Date Tue, 28 Apr 2015 13:05:46 GMT
Fixing broken tests.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/34c7edb1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/34c7edb1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/34c7edb1

Branch: refs/heads/master
Commit: 34c7edb1dd7ed710d85d18b44e89e362821143d9
Parents: 7c30890
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Tue Apr 28 09:00:49 2015 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Tue Apr 28 09:00:49 2015 -0400

----------------------------------------------------------------------
 .../src/test/java/org/apache/blur/hive/BlurSerDeTest.java     | 2 +-
 .../java/org/apache/blur/mapreduce/lib/update/DriverTest.java | 7 +++----
 2 files changed, 4 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/34c7edb1/blur-hive/src/test/java/org/apache/blur/hive/BlurSerDeTest.java
----------------------------------------------------------------------
diff --git a/blur-hive/src/test/java/org/apache/blur/hive/BlurSerDeTest.java b/blur-hive/src/test/java/org/apache/blur/hive/BlurSerDeTest.java
index 182b6bb..d343fcd 100644
--- a/blur-hive/src/test/java/org/apache/blur/hive/BlurSerDeTest.java
+++ b/blur-hive/src/test/java/org/apache/blur/hive/BlurSerDeTest.java
@@ -298,7 +298,7 @@ public class BlurSerDeTest {
     String outputPathStr = miniCluster.getFileSystemUri().toString() + "/indexoutput";
     String blurZkConnection = miniCluster.getZkConnectionString();
 
-    assertEquals(0, driver.run(new String[] { TEST, _mrWorkingPath, outputPathStr, blurZkConnection
}));
+    assertEquals(0, driver.run(new String[] { TEST, _mrWorkingPath, outputPathStr, blurZkConnection,
"1" }));
 
     Iface client = BlurClient.getClientFromZooKeeperConnectionStr(blurZkConnection);
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/34c7edb1/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/update/DriverTest.java
----------------------------------------------------------------------
diff --git a/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/update/DriverTest.java
b/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/update/DriverTest.java
index 4d2e977..9232e1a 100644
--- a/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/update/DriverTest.java
+++ b/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/update/DriverTest.java
@@ -26,7 +26,6 @@ import java.util.UUID;
 
 import org.apache.blur.MiniCluster;
 import org.apache.blur.mapreduce.lib.BlurRecord;
-import org.apache.blur.mapreduce.lib.update.Driver;
 import org.apache.blur.store.buffer.BufferStore;
 import org.apache.blur.thirdparty.thrift_0_9_0.TException;
 import org.apache.blur.thrift.BlurClient;
@@ -122,7 +121,7 @@ public class DriverTest {
     String outputPathStr = new Path(root, "output").toString();
     String blurZkConnection = miniCluster.getZkConnectionString();
 
-    assertEquals(0, driver.run(new String[] { tableName, mrIncWorkingPathStr, outputPathStr,
blurZkConnection }));
+    assertEquals(0, driver.run(new String[] { tableName, mrIncWorkingPathStr, outputPathStr,
blurZkConnection, "1" }));
 
     Iface client = getClient();
     client.loadData(tableName, outputPathStr);
@@ -152,7 +151,7 @@ public class DriverTest {
     String outputPathStr = new Path(root, "output").toString();
     String blurZkConnection = miniCluster.getZkConnectionString();
 
-    assertEquals(0, driver.run(new String[] { tableName, mrIncWorkingPathStr, outputPathStr,
blurZkConnection }));
+    assertEquals(0, driver.run(new String[] { tableName, mrIncWorkingPathStr, outputPathStr,
blurZkConnection, "1" }));
 
     client.loadData(tableName, outputPathStr);
 
@@ -183,7 +182,7 @@ public class DriverTest {
     String outputPathStr = new Path(root, "output").toString();
     String blurZkConnection = miniCluster.getZkConnectionString();
 
-    assertEquals(0, driver.run(new String[] { tableName, mrIncWorkingPathStr, outputPathStr,
blurZkConnection }));
+    assertEquals(0, driver.run(new String[] { tableName, mrIncWorkingPathStr, outputPathStr,
blurZkConnection, "1" }));
     {
       Selector selector = new Selector();
       selector.setRowId(rowId);


Mime
View raw message