From 5a4dcf1c7c6f4d327790466f0ebcbe95221f3ac9 Mon Sep 17 00:00:00 2001 From: Mahesh Kumar Behera Date: Fri, 4 May 2018 23:52:47 +0530 Subject: [PATCH] HIVE-19423 : REPL LOAD creates staging directory in source dump directory instead of table data location --- .../apache/hadoop/hive/ql/exec/repl/bootstrap/load/table/LoadTable.java | 2 +- ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 e2ec4aff48..d10ca76aa0 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 @@ private void existingTableTasks(ImportTableDesc tblDesc, Table table, 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); } 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 fa32807c53..e6a70121f0 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 @@ private static void createReplImportTasks( 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)); -- 2.14.3 (Apple Git-98)