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 <[email protected]>
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),
