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..5105d1290b 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, event.metadataPath(), table.getDataLocation()); 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));