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 35ea777ef5..07ee913b24 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 @@ -185,6 +185,9 @@ private ReplLoadOpType getLoadTableType(Table table, boolean isBootstrapDuringIn private void newTableTasks(ImportTableDesc tblDesc, Task tblRootTask, TableLocationTuple tuple) throws Exception { Table table = tblDesc.toTable(context.hiveConf); + if (!tblDesc.isExternal()) { + tblDesc.setLocation(null); + } ReplicationSpec replicationSpec = event.replicationSpec(); Task createTableTask = tblDesc.getCreateTableTask(new HashSet<>(), new HashSet<>(), context.hiveConf); @@ -224,7 +227,7 @@ private void newTableTasks(ImportTableDesc tblDesc, Task tblRootTask, TableLo ) || tuple.isConvertedFromManagedToExternal; if (shouldCreateLoadTableTask) { LOG.debug("adding dependent ReplTxnTask/CopyWork/MoveWork for table"); - Task loadTableTask = loadTableTask(table, replicationSpec, new Path(tblDesc.getLocation()), + Task loadTableTask = loadTableTask(table, replicationSpec, table.getDataLocation(), event.dataPath()); parentTask.addDependentTask(loadTableTask); }