From 28544657d5329d17165fa12134215f5dc37815de Mon Sep 17 00:00:00 2001 From: Yang Yang Date: Mon, 17 May 2021 17:35:55 +0800 Subject: [PATCH] Fix the cluster config name --- .../src/main/java/io/functionmesh/compute/util/CommonUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mesh-worker-service/src/main/java/io/functionmesh/compute/util/CommonUtil.java b/mesh-worker-service/src/main/java/io/functionmesh/compute/util/CommonUtil.java index 6125d6d4e..36d030b94 100644 --- a/mesh-worker-service/src/main/java/io/functionmesh/compute/util/CommonUtil.java +++ b/mesh-worker-service/src/main/java/io/functionmesh/compute/util/CommonUtil.java @@ -36,7 +36,7 @@ public static String getDefaultPulsarConfig() { } public static String getPulsarClusterConfigMapName(String cluster) { - return toValidResourceName(String.format("%s-pulsar-config-map", cluster)); // Need to manage the configMap for each Pulsar Cluster + return toValidResourceName(String.format("%s-function-mesh-config", cluster)); // Need to manage the configMap for each Pulsar Cluster } public static String getPulsarClusterAuthConfigMapName(String cluster) {