Repository: crunch Updated Branches: refs/heads/master 23a2da07d -> 4df441907
Fix HCatSourceITSpec.testBasic Signed-off-by: Josh Wills <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/4df44190 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/4df44190 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/4df44190 Branch: refs/heads/master Commit: 4df441907bc22ec54d9eb58bd637f8da70eaf9a9 Parents: 23a2da0 Author: Clément MATHIEU <[email protected]> Authored: Tue Mar 6 17:47:48 2018 +0100 Committer: Josh Wills <[email protected]> Committed: Fri Mar 9 14:46:03 2018 -0800 ---------------------------------------------------------------------- .../it/java/org/apache/crunch/io/hcatalog/HCatSourceITSpec.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/4df44190/crunch-hcatalog/src/it/java/org/apache/crunch/io/hcatalog/HCatSourceITSpec.java ---------------------------------------------------------------------- diff --git a/crunch-hcatalog/src/it/java/org/apache/crunch/io/hcatalog/HCatSourceITSpec.java b/crunch-hcatalog/src/it/java/org/apache/crunch/io/hcatalog/HCatSourceITSpec.java index 676b1fe..49394c9 100644 --- a/crunch-hcatalog/src/it/java/org/apache/crunch/io/hcatalog/HCatSourceITSpec.java +++ b/crunch-hcatalog/src/it/java/org/apache/crunch/io/hcatalog/HCatSourceITSpec.java @@ -95,7 +95,7 @@ public class HCatSourceITSpec extends CrunchTestSupport { Path tableRootLocation = temporaryPath.getPath(tableName); String data = "17,josh\n29,indiana\n"; writeDataToHdfs(data, tableRootLocation, conf); - HCatTestUtils.createUnpartitionedTable(client, tableName, TableType.MANAGED_TABLE); + HCatTestUtils.createUnpartitionedTable(client, tableName, TableType.MANAGED_TABLE, tableRootLocation); Pipeline p = new MRPipeline(HCatSourceITSpec.class, conf); HCatSourceTarget src = (HCatSourceTarget) FromHCat.table(tableName);
