Include keys for arguments passed to HCatalogMR

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

Branch: refs/heads/BIGTOP-1406
Commit: 5f6bc8b5327ac07996ce875d9b7ba6ebacd4529d
Parents: 971f425
Author: Raj Desai <[email protected]>
Authored: Thu Jan 19 15:12:12 2017 -0800
Committer: Roman Shaposhnik <[email protected]>
Committed: Fri Feb 24 12:03:54 2017 -0800

----------------------------------------------------------------------
 .../src/test/java/org/odpi/specs/runtime/hive/TestHCatalog.java  | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/bigtop/blob/5f6bc8b5/bigtop-tests/spec-tests/runtime/src/test/java/org/odpi/specs/runtime/hive/TestHCatalog.java
----------------------------------------------------------------------
diff --git 
a/bigtop-tests/spec-tests/runtime/src/test/java/org/odpi/specs/runtime/hive/TestHCatalog.java
 
b/bigtop-tests/spec-tests/runtime/src/test/java/org/odpi/specs/runtime/hive/TestHCatalog.java
index b51db02..0ea49ce 100644
--- 
a/bigtop-tests/spec-tests/runtime/src/test/java/org/odpi/specs/runtime/hive/TestHCatalog.java
+++ 
b/bigtop-tests/spec-tests/runtime/src/test/java/org/odpi/specs/runtime/hive/TestHCatalog.java
@@ -140,9 +140,13 @@ public class TestHCatalog {
         .addArgument("jar")
         .addArgument(System.getProperty(JOBJAR))
         .addArgument(HCatalogMR.class.getName())
+        .addArgument("-it")
         .addArgument(inputTable)
+        .addArgument("-ot")
         .addArgument(outputTable)
+        .addArgument("-is")
         .addArgument(inputSchema.getSchemaAsTypeString())
+        .addArgument("-os")
         .addArgument(outputSchema.getSchemaAsTypeString()), env);
     LOG.info(results.toString());
     Assert.assertEquals("HCat job failed", 0, 
Integer.parseInt(results.get("exitValue")));

Reply via email to