Repository: hive Updated Branches: refs/heads/branch-3 6e2a85a9e -> f93f76d18 (forced update)
HIVE-19423 : REPL LOAD creates staging directory in source dump directory instead of table data location (Mahesh Kumar Behera, reviewed by Sankar Hariappan) Signed-off-by: Sankar Hariappan <sank...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f93f76d1 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f93f76d1 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f93f76d1 Branch: refs/heads/branch-3 Commit: f93f76d183efcf5cfcebc834aad56868fcde14bf Parents: 61ec445 Author: Mahesh Kumar Behera <mbeh...@hortonworks.com> Authored: Fri May 4 23:52:47 2018 +0530 Committer: Sankar Hariappan <sank...@apache.org> Committed: Tue May 8 00:01:56 2018 +0530 ---------------------------------------------------------------------- .../hadoop/hive/ql/exec/repl/bootstrap/load/table/LoadTable.java | 2 +- .../org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/f93f76d1/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/bootstrap/load/table/LoadTable.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/bootstrap/load/table/LoadTable.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/bootstrap/load/table/LoadTable.java index e2ec4af..d10ca76 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/bootstrap/load/table/LoadTable.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/bootstrap/load/table/LoadTable.java @@ -182,7 +182,7 @@ public class LoadTable { tracker.addTask(alterTableTask); } else { Task<?> loadTableTask = - loadTableTask(table, replicationSpec, event.metadataPath(), event.metadataPath()); + loadTableTask(table, replicationSpec, table.getDataLocation(), event.metadataPath()); alterTableTask.addDependentTask(loadTableTask); tracker.addTask(alterTableTask); } http://git-wip-us.apache.org/repos/asf/hive/blob/f93f76d1/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java index fa32807..e6a7012 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java @@ -1079,7 +1079,7 @@ public class ImportSemanticAnalyzer extends BaseSemanticAnalyzer { x.getLOG().debug("table non-partitioned"); if (!replicationSpec.isMetadataOnly()) { // repl-imports are replace-into unless the event is insert-into - loadTable(fromURI, table, replicationSpec.isReplace(), new Path(fromURI), + loadTable(fromURI, table, replicationSpec.isReplace(), table.getDataLocation(), replicationSpec, x, writeId, stmtId, isSourceMm); } else { x.getTasks().add(alterTableTask(tblDesc, x, replicationSpec));