syncer: Set the health label to no before updating pod. radondb#310

runkecheng · Nov 29, 2021 · bf857f0 · bf857f0
1 parent 98a9110
commit bf857f0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/mysqlcluster/syncer/statefulset.go b/mysqlcluster/syncer/statefulset.go
@@ -580,6 +580,10 @@ func (s *StatefulSetSyncer) applyNWait(ctx context.Context, pod *corev1.Pod) err
 		if pod.DeletionTimestamp != nil {
 			log.Info("pod is being deleted", "pod", pod.Name, "key", s.Unwrap())
 		} else {
+			pod.ObjectMeta.Labels["healthy"] = "no"
+			if err := s.cli.Update(ctx, pod); err != nil {
+				return err
+			}
 			if err := s.cli.Delete(ctx, pod); err != nil {
 				return err
 			}