You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2020/07/22 02:14:06 UTC
[rocketmq-operator] branch master updated: [ISSUE #21] Distinguish
between brokerName and brokerClusterName (#22)
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-operator.git
The following commit(s) were added to refs/heads/master by this push:
new 4f78b3f [ISSUE #21] Distinguish between brokerName and brokerClusterName (#22)
4f78b3f is described below
commit 4f78b3fac5734dbdd0491620231816f0a2ec7d47
Author: jiangzhihui <83...@qq.com>
AuthorDate: Wed Jul 22 10:14:01 2020 +0800
[ISSUE #21] Distinguish between brokerName and brokerClusterName (#22)
---
pkg/controller/broker/broker_controller.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pkg/controller/broker/broker_controller.go b/pkg/controller/broker/broker_controller.go
index b3e6cf6..6c22dcc 100644
--- a/pkg/controller/broker/broker_controller.go
+++ b/pkg/controller/broker/broker_controller.go
@@ -406,7 +406,7 @@ func (r *ReconcileBroker) getBrokerStatefulSet(broker *rocketmqv1alpha1.Broker,
Value: strconv.Itoa(replicaIndex),
}, {
Name: cons.EnvBrokerClusterName,
- Value: broker.Name + "-" + strconv.Itoa(brokerGroupIndex),
+ Value: broker.Name,
}, {
Name: cons.EnvBrokerName,
Value: broker.Name + "-" + strconv.Itoa(brokerGroupIndex),