From e3c98ed9a6745f594304ff53e7faed6b66e3e657 Mon Sep 17 00:00:00 2001 From: pengys5 <8082209@qq.com> Date: Fri, 3 Mar 2017 21:11:01 +0800 Subject: [PATCH] no message --- .../worker/application/persistence/DAGNodePersistence.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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