diff --git a/cat-hadoop/src/main/java/com/dianping/cat/hadoop/hdfs/DumpUploader.java b/cat-hadoop/src/main/java/com/dianping/cat/hadoop/hdfs/DumpUploader.java index a2c391c70419a9974aaa7484b1d820cb90b25857..63e0f0422c55699c7f05222e8c89e4f9e49cfd5e 100644 --- a/cat-hadoop/src/main/java/com/dianping/cat/hadoop/hdfs/DumpUploader.java +++ b/cat-hadoop/src/main/java/com/dianping/cat/hadoop/hdfs/DumpUploader.java @@ -56,6 +56,11 @@ public class DumpUploader implements Initializable, LogEnabled { @Override public void initialize() throws InitializationException { m_baseDir = m_configManager.getHdfsLocalBaseDir("dump"); + if (!m_configManager.isLocalMode()) { + if (m_job == null) { + m_job = Threads.forGroup("Cat").start(new WriteJob()); + } + } } private FSDataOutputStream makeHdfsOutputStream(String path) throws IOException { @@ -71,13 +76,6 @@ public class DumpUploader implements Initializable, LogEnabled { m_sleepPeriod = period; } - public void start() { - // only start at first time and long running - if (m_job == null) { - m_job = Threads.forGroup("Cat").start(new WriteJob()); - } - } - class WriteJob implements Task { private volatile boolean m_active = true; diff --git a/cat-home/src/main/java/com/dianping/cat/CatHomeModule.java b/cat-home/src/main/java/com/dianping/cat/CatHomeModule.java index a0ddcd0d0708f8f009706caa5c014bfb71b4eeae..6666d445dd814cd3defffa8beb3f8f5e90ad0041 100644 --- a/cat-home/src/main/java/com/dianping/cat/CatHomeModule.java +++ b/cat-home/src/main/java/com/dianping/cat/CatHomeModule.java @@ -10,6 +10,7 @@ import org.unidal.initialization.ModuleContext; import com.dianping.cat.consumer.CatConsumerAdvancedModule; import com.dianping.cat.consumer.CatConsumerModule; import com.dianping.cat.consumer.problem.aggregation.AggregationConfigManager; +import com.dianping.cat.hadoop.hdfs.DumpUploader; import com.dianping.cat.message.spi.core.MessageConsumer; import com.dianping.cat.message.spi.core.TcpSocketReceiver; import com.dianping.cat.report.task.DefaultTaskConsumer; @@ -29,7 +30,7 @@ public class CatHomeModule extends AbstractModule { @Override protected void execute(ModuleContext ctx) throws Exception { ServerConfigManager serverConfigManager = ctx.lookup(ServerConfigManager.class); - + ctx.lookup(DumpUploader.class); ctx.lookup(MessageConsumer.class); ctx.lookup(DomainNavManager.class); ctx.lookup(AggregationConfigManager.class); diff --git a/cat-home/src/main/java/com/dianping/cat/helper/Parse.java b/cat-home/src/main/java/com/dianping/cat/helper/Parse.java deleted file mode 100644 index 2ff88df1e90dbc6db69ab5e6931e45f92278b6b2..0000000000000000000000000000000000000000 --- a/cat-home/src/main/java/com/dianping/cat/helper/Parse.java +++ /dev/null @@ -1,12 +0,0 @@ -package com.dianping.cat.helper; - -import java.util.Date; -import java.util.List; -import java.util.Map; - -public interface Parse { - - public double[] compute(Map> datas); - - public void setDateNoUse(Date start,Date end); -}