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 6fbe29c5ec..e59e9b1931 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 @@ -565,6 +565,16 @@ private static ImportTableDesc getBaseCreateTableDescFromTable(String dbName, moveWork.setLoadTableWork(loadTableWork); } + if (replicationSpec.isInReplicationScope() && !AcidUtils.isTransactionalTable(tblDesc.getTblProps())) { + // TODO : if move optimization is enabled and copy is done directly to target, then in case of add partition + // event, move task can be ignored. + if (x.getEventType() == DumpType.EVENT_INSERT) { + Task loadPartTask = TaskFactory.get(moveWork, x.getConf()); + copyTask.addDependentTask(loadPartTask); + return copyTask; + } + } + Task loadPartTask = TaskFactory.get(moveWork, x.getConf()); copyTask.addDependentTask(loadPartTask); addPartTask.addDependentTask(loadPartTask);