diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/AtlasDumpTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/AtlasDumpTask.java index 8036e51ac4..d2d101ee07 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/AtlasDumpTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/AtlasDumpTask.java @@ -98,9 +98,9 @@ public int execute() { AtlasRequestBuilder atlasRequestBuilder = new AtlasRequestBuilder(); String entityGuid = checkHiveEntityGuid(atlasRequestBuilder, atlasReplInfo.getSrcCluster(), atlasReplInfo.getSrcDB()); - long currentModifiedTime = getCurrentTimestamp(atlasReplInfo, entityGuid); long numBytesWritten = dumpAtlasMetaData(atlasRequestBuilder, atlasReplInfo); LOG.debug("Finished dumping atlas metadata, total:{} bytes written", numBytesWritten); + long currentModifiedTime = getCurrentTimestamp(atlasReplInfo, entityGuid); createDumpMetadata(atlasReplInfo, currentModifiedTime); replLogger.endLog(0L); work.getMetricCollector().reportStageEnd(getName(), Status.SUCCESS);