diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/application/persistence/DAGNodePersistence.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/application/persistence/DAGNodePersistence.java index ce6119e0e..cfcb59f82 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/application/persistence/DAGNodePersistence.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/application/persistence/DAGNodePersistence.java @@ -1,15 +1,19 @@ package com.a.eye.skywalking.collector.worker.application.persistence; import com.a.eye.skywalking.collector.actor.AbstractWorkerProvider; -import com.a.eye.skywalking.collector.worker.WorkerConfig; import com.a.eye.skywalking.collector.worker.PersistenceWorker; +import com.a.eye.skywalking.collector.worker.WorkerConfig; import com.google.gson.JsonObject; +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; /** * @author pengys5 */ public class DAGNodePersistence extends PersistenceWorker { + private Logger logger = LogManager.getFormatterLogger(DAGNodePersistence.class); + @Override public String esIndex() { return "application"; @@ -29,6 +33,7 @@ public class DAGNodePersistence extends PersistenceWorker