fix: selector pod to request EMQX API

some times operator controller will pick deleted pod to request EMQX API Signed-off-by: Rory Z <[email protected]>
emqx · Mar 6, 2024 · 5c3cbf4 · 5c3cbf4
1 parent 22a0cf7
commit 5c3cbf4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/controllers/apps/v2beta1/emqx_controller.go b/controllers/apps/v2beta1/emqx_controller.go
@@ -197,7 +197,7 @@ func newRequester(ctx context.Context, k8sClient client.Client, instance *appsv2
 	})
 
 	for _, pod := range podList.Items {
-		if pod.Status.Phase == corev1.PodRunning && pod.Status.PodIP != "" {
+		if pod.GetDeletionTimestamp() == nil && pod.Status.Phase == corev1.PodRunning && pod.Status.PodIP != "" {
 			return &innerReq.Requester{
 				Schema:   schema,
 				Host:     net.JoinHostPort(pod.Status.PodIP, port),