From ce02f452163c18d374f98f3c4e7ec80e387ed99f Mon Sep 17 00:00:00 2001
From: pengys5 <8082209@qq.com>
Date: Sun, 10 Sep 2017 23:32:40 +0800
Subject: [PATCH] no message

---
 .../skywalking/apm/collector/boot/CollectorStarter.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/apm-collector/apm-collector-boot/src/main/java/org/skywalking/apm/collector/boot/CollectorStarter.java b/apm-collector/apm-collector-boot/src/main/java/org/skywalking/apm/collector/boot/CollectorStarter.java
index 3f7c12922d..affe9dc74f 100644
--- a/apm-collector/apm-collector-boot/src/main/java/org/skywalking/apm/collector/boot/CollectorStarter.java
+++ b/apm-collector/apm-collector-boot/src/main/java/org/skywalking/apm/collector/boot/CollectorStarter.java
@@ -1,6 +1,7 @@
 package org.skywalking.apm.collector.boot;
 
 import java.util.Map;
+import org.skywalking.apm.collector.cluster.ClusterModuleGroupDefine;
 import org.skywalking.apm.collector.core.CollectorException;
 import org.skywalking.apm.collector.core.framework.Starter;
 import org.skywalking.apm.collector.core.module.ModuleConfigLoader;
@@ -39,8 +40,12 @@ public class CollectorStarter implements Starter {
             moduleGroupDefine.moduleInstaller().preInstall();
         }
 
+        moduleGroupDefineMap.get(ClusterModuleGroupDefine.GROUP_NAME).moduleInstaller().install();
+
         for (ModuleGroupDefine moduleGroupDefine : moduleGroupDefineMap.values()) {
-            moduleGroupDefine.moduleInstaller().install();
+            if (!(moduleGroupDefine instanceof ClusterModuleGroupDefine)) {
+                moduleGroupDefine.moduleInstaller().install();
+            }
         }
 
         serverHolder.getServers().forEach(server -> {
-- 
GitLab