diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/storage/EsClient.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/storage/EsClient.java
index c1f91d2ccfab87185349ae811a2d71123af7fa2c..a50ed93cb0fdd274cf76071c11daf60a86570196 100644
--- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/storage/EsClient.java
+++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/storage/EsClient.java
@@ -28,7 +28,7 @@ public enum EsClient {
 
     public void boot() throws UnknownHostException {
         Settings settings = Settings.builder()
-            .put("cluster.NAME", EsConfig.Es.Cluster.NAME)
+            .put("cluster.name", EsConfig.Es.Cluster.NAME)
             .put("client.transport.sniff", EsConfig.Es.Cluster.Transport.SNIFFER)
             .build();