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/1df0c5d5
Tree: http://git-wip-us.apache.org/repos/asf/bigtop/tree/1df0c5d5
Diff: http://git-wip-us.apache.org/repos/asf/bigtop/diff/1df0c5d5

Branch: refs/heads/BIGTOP-2666
Commit: 1df0c5d55f9e5c2c618a9261707e831e30687f8e
Parents: ebe22bc
Author: Raj Desai <[email protected]>
Authored: Thu Jan 19 15:12:12 2017 -0800
Committer: Roman Shaposhnik <[email protected]>
Committed: Fri Feb 24 11:51:26 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/1df0c5d5/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