fix: selector pod to request EMQX API

Signed-off-by: Rory Z <[email protected]>
emqx · Oct 9, 2023 · b34242e · b34242e
1 parent a32a33e
commit b34242e
Showing 1 changed file with 3 additions and 10 deletions.
diff --git a/controllers/apps/v2beta1/emqx_controller.go b/controllers/apps/v2beta1/emqx_controller.go
@@ -171,19 +171,12 @@ func newRequester(k8sClient client.Client, instance *appsv2beta1.EMQX) (innerReq
 		port = dashboardPort.TargetPort.String()
 	}
 
-	labels := appsv2beta1.DefaultCoreLabels(instance)
-	if instance.Status.CoreNodesStatus.CurrentRevision != "" {
-		labels = appsv2beta1.CloneAndAddLabel(
-			labels,
-			appsv2beta1.LabelsPodTemplateHashKey,
-			instance.Status.CoreNodesStatus.CurrentRevision,
-		)
-	}
-
 	podList := &corev1.PodList{}
 	_ = k8sClient.List(context.Background(), podList,
 		client.InNamespace(instance.Namespace),
-		client.MatchingLabels(labels),
+		client.MatchingLabels(
+			appsv2beta1.DefaultCoreLabels(instance),
+		),
 	)
 	sort.Slice(podList.Items, func(i, j int) bool {
 		return podList.Items[i].CreationTimestamp.Before(&podList.Items[j].CreationTimestamp)