diff --git a/config/src/main/java/com/alibaba/nacos/config/server/service/dump/DumpService.java b/config/src/main/java/com/alibaba/nacos/config/server/service/dump/DumpService.java index 5e706e15d15..146c80476b7 100755 --- a/config/src/main/java/com/alibaba/nacos/config/server/service/dump/DumpService.java +++ b/config/src/main/java/com/alibaba/nacos/config/server/service/dump/DumpService.java @@ -67,6 +67,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; +import static com.alibaba.nacos.config.server.utils.LogUtil.DUMP_LOG; import static com.alibaba.nacos.config.server.utils.LogUtil.FATAL_LOG; /** @@ -343,15 +344,25 @@ public void dump(String dataId, String group, String tenant, long lastModified, dump(dataId, group, tenant, lastModified, handleIp, false); } + /** + * Add DumpTask to TaskManager, it will execute asynchronously. + */ public void dump(String dataId, String group, String tenant, long lastModified, String handleIp, boolean isBeta) { String groupKey = GroupKey2.getKey(dataId, group, tenant); - dumpTaskMgr.addTask(groupKey, new DumpTask(groupKey, lastModified, handleIp, isBeta)); + String taskKey = String.join("+", dataId, group, tenant, String.valueOf(isBeta)); + dumpTaskMgr.addTask(taskKey, new DumpTask(groupKey, lastModified, handleIp, isBeta)); + DUMP_LOG.info("[dump-task] add task. groupKey={}, taskKey={}", groupKey, taskKey); } + /** + * Add DumpTask to TaskManager, it will execute asynchronously. + */ public void dump(String dataId, String group, String tenant, String tag, long lastModified, String handleIp, boolean isBeta) { String groupKey = GroupKey2.getKey(dataId, group, tenant); - dumpTaskMgr.addTask(groupKey, new DumpTask(groupKey, tag, lastModified, handleIp, isBeta)); + String taskKey = String.join("+", dataId, group, tenant, String.valueOf(isBeta), tag); + dumpTaskMgr.addTask(taskKey, new DumpTask(groupKey, tag, lastModified, handleIp, isBeta)); + DUMP_LOG.info("[dump-task] add task. groupKey={}, taskKey={}", groupKey, taskKey); } public void dumpAll() {