diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java index cbf0561dfe..b280ed88b1 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java @@ -1893,7 +1893,13 @@ public int execute(boolean deferClose) throws CommandNeedRetryException { if (tskRun == null) { continue; } - hookContext.addCompleteTask(tskRun); + String opName = plan.getOperationName(); + boolean isReplicationOperation = opName.equals(HiveOperation.REPLDUMP.getOperationName()) + || opName.equals(HiveOperation.REPLLOAD.getOperationName()); + if (!isReplicationOperation) { + hookContext.addCompleteTask(tskRun); + } + queryDisplay.setTaskResult(tskRun.getTask().getId(), tskRun.getTaskResult()); Task tsk = tskRun.getTask();