@Override
  public int execute() {
    try {
      for(PreAckTask task : work.getPreAckTasks()) {
        task.run();
      }
      Path ackPath = work.getAckFilePath();
      Utils.create(ackPath, conf);
      LOG.info("Created ack file : {} ", ackPath);
    } catch (Exception e) {
      setException(e);
      int errorCode = ErrorMsg.getErrorMsg(e.getMessage()).getErrorCode();
      try {
        return ReplUtils.handleException(true, e, work.getAckFilePath().getParent().getParent().toString(),
                work.getMetricCollector(), getName(), conf);
      } catch (Exception ex){
        LOG.error("Failed to collect replication metrics: ", ex);
        return errorCode;
      }
    }
    return 0;
  }
AckTask.

Add the repl dump/ repl load complete acknowledgement.
ql/src/java/org/apache/hadoop/hive/ql/exec/repl/AckTask.java