Repository: tajo
Updated Branches:
  refs/heads/branch-0.11.0 6c0f771d9 -> 207421ac5


TAJO-1811: Catalog server address must be set dynamically during test.


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

Branch: refs/heads/branch-0.11.0
Commit: 207421ac5cc7d931415a20675a42c6c8c35ac95f
Parents: 6c0f771
Author: Jihoon Son <[email protected]>
Authored: Thu Sep 3 22:36:24 2015 +0900
Committer: Jihoon Son <[email protected]>
Committed: Thu Sep 3 22:36:24 2015 +0900

----------------------------------------------------------------------
 CHANGES                                                           | 3 +++
 .../src/test/java/org/apache/tajo/catalog/CatalogTestingUtil.java | 2 ++
 .../src/test/java/org/apache/tajo/CatalogTestingUtil.java         | 2 ++
 .../src/test/java/org/apache/tajo/QueryTestCaseBase.java          | 3 ++-
 4 files changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tajo/blob/207421ac/CHANGES
----------------------------------------------------------------------
diff --git a/CHANGES b/CHANGES
index 3aa579f..c3a712f 100644
--- a/CHANGES
+++ b/CHANGES
@@ -242,6 +242,9 @@ Release 0.11.0 - unreleased
 
   BUG FIXES
 
+    TAJO-1811: Catalog server address must be set dynamically during test.
+    (jihoon)
+
     TAJO-1802: PythonScriptEngine copies controller and tajo util whenever 
     it is initialized. (jihoon)
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/207421ac/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/CatalogTestingUtil.java
----------------------------------------------------------------------
diff --git 
a/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/CatalogTestingUtil.java
 
b/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/CatalogTestingUtil.java
index 924c0bb..22fc23a 100644
--- 
a/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/CatalogTestingUtil.java
+++ 
b/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/CatalogTestingUtil.java
@@ -22,6 +22,7 @@ import org.apache.tajo.annotation.NotNull;
 import org.apache.tajo.annotation.Nullable;
 import org.apache.tajo.catalog.store.*;
 import org.apache.tajo.conf.TajoConf;
+import org.apache.tajo.conf.TajoConf.ConfVars;
 import org.apache.tajo.exception.UnsupportedCatalogStore;
 
 public class CatalogTestingUtil {
@@ -53,6 +54,7 @@ public class CatalogTestingUtil {
                                                                                
String catalogUri) {
     conf.set(CatalogConstants.STORE_CLASS, catalogClass.getCanonicalName());
     conf.set(CatalogConstants.CATALOG_URI, catalogUri);
+    conf.setVar(ConfVars.CATALOG_ADDRESS, "localhost:0");
     return conf;
   }
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/207421ac/tajo-cluster-tests/src/test/java/org/apache/tajo/CatalogTestingUtil.java
----------------------------------------------------------------------
diff --git 
a/tajo-cluster-tests/src/test/java/org/apache/tajo/CatalogTestingUtil.java 
b/tajo-cluster-tests/src/test/java/org/apache/tajo/CatalogTestingUtil.java
index cbc409b..3f45ede 100644
--- a/tajo-cluster-tests/src/test/java/org/apache/tajo/CatalogTestingUtil.java
+++ b/tajo-cluster-tests/src/test/java/org/apache/tajo/CatalogTestingUtil.java
@@ -23,6 +23,7 @@ import org.apache.tajo.annotation.Nullable;
 import org.apache.tajo.catalog.CatalogConstants;
 import org.apache.tajo.catalog.store.*;
 import org.apache.tajo.conf.TajoConf;
+import org.apache.tajo.conf.TajoConf.ConfVars;
 import org.apache.tajo.exception.UnsupportedCatalogStore;
 
 public class CatalogTestingUtil {
@@ -54,6 +55,7 @@ public class CatalogTestingUtil {
                                                                                
String catalogUri) {
     conf.set(CatalogConstants.STORE_CLASS, catalogClass.getCanonicalName());
     conf.set(CatalogConstants.CATALOG_URI, catalogUri);
+    conf.setVar(ConfVars.CATALOG_ADDRESS, "localhost:0");
     return conf;
   }
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/207421ac/tajo-cluster-tests/src/test/java/org/apache/tajo/QueryTestCaseBase.java
----------------------------------------------------------------------
diff --git 
a/tajo-cluster-tests/src/test/java/org/apache/tajo/QueryTestCaseBase.java 
b/tajo-cluster-tests/src/test/java/org/apache/tajo/QueryTestCaseBase.java
index bfafd6d..f521587 100644
--- a/tajo-cluster-tests/src/test/java/org/apache/tajo/QueryTestCaseBase.java
+++ b/tajo-cluster-tests/src/test/java/org/apache/tajo/QueryTestCaseBase.java
@@ -979,7 +979,8 @@ public class QueryTestCaseBase {
       if (expr.getType() == OpType.CreateTable) {
         CreateTable createTable = (CreateTable) expr;
         String tableName = createTable.getTableName();
-        assertTrue("Table [" + tableName + "] creation is failed.", 
client.updateQuery(parsedResult.getHistoryStatement()));
+        assertTrue("Table [" + tableName + "] creation is failed.",
+            client.updateQuery(parsedResult.getHistoryStatement()));
 
         TableDesc createdTable = client.getTableDesc(tableName);
         String createdTableName = createdTable.getName();

Reply via email to