incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject git commit: Fixed broken test.
Date Thu, 23 Apr 2015 11:54:14 GMT
Repository: incubator-blur
Updated Branches:
  refs/heads/master 594b661ed -> be53426e4


Fixed broken test.


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

Branch: refs/heads/master
Commit: be53426e48e3bd0652585f9a35b32ec02c839af6
Parents: 594b661
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Thu Apr 23 07:54:10 2015 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Thu Apr 23 07:54:10 2015 -0400

----------------------------------------------------------------------
 blur-hive/src/test/java/org/apache/blur/hive/BlurSerDeTest.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be53426e/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 fda4f20..182b6bb 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
@@ -122,6 +122,7 @@ public class BlurSerDeTest {
 
   @Before
   public void setup() throws BlurException, TException, IOException {
+    _mrWorkingPath = miniCluster.getFileSystemUri().toString() + "/mrworkingpath";
     String controllerConnectionStr = miniCluster.getControllerConnectionStr();
     Iface client = BlurClient.getClient(controllerConnectionStr);
     List<String> tableList = client.tableList();
@@ -130,8 +131,6 @@ public class BlurSerDeTest {
       tableDescriptor.setName(TEST);
       tableDescriptor.setShardCount(1);
       tableDescriptor.setTableUri(miniCluster.getFileSystemUri().toString() + "/blur/tables/test");
-
-      _mrWorkingPath = miniCluster.getFileSystemUri().toString() + "/mrworkingpath";
       tableDescriptor.putToTableProperties(BlurSerDe.BLUR_MR_UPDATE_WORKING_PATH, _mrWorkingPath);
 
       client.createTable(tableDescriptor);
@@ -365,11 +364,13 @@ public class BlurSerDeTest {
     run(connection, "set " + BlurSerDe.BLUR_BLOCKING_APPLY + "=true");
     run(connection, "insert into table testtable select * from loadtable");
     connection.close();
+    hiveServer2.stop();
     return totalRecords;
   }
 
   private void generateData(File file, int totalRecords) throws IOException {
     SimpleDateFormat simpleDateFormat = new SimpleDateFormat(YYYY_MM_DD);
+    file.mkdirs();
     PrintWriter print = new PrintWriter(new File(file, "data"));
     Date date = new Date(System.currentTimeMillis());
     for (int i = 0; i < totalRecords; i++) {


Mime
View raw message