You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/05/07 17:14:14 UTC
hive git commit: HIVE-19423 : REPL LOAD creates staging directory in
source dump directory instead of table data location
Repository: hive
Updated Branches:
refs/heads/master 7584b3276 -> 04f5c6020
HIVE-19423 : REPL LOAD creates staging directory in source dump directory instead of table data location
Signed-off-by: Sankar Hariappan <sa...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/04f5c602
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/04f5c602
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/04f5c602
Branch: refs/heads/master
Commit: 04f5c6020f06669447047e076813ea90ba4e4371
Parents: 7584b32
Author: Mahesh Kumar Behera <mb...@hortonworks.com>
Authored: Fri May 4 23:52:47 2018 +0530
Committer: Sankar Hariappan <sa...@apache.org>
Committed: Mon May 7 22:43:36 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/04f5c602/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/04f5c602/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));