optimize observer recover logic

oceanbase · Apr 23, 2024 · e8b1174 · e8b1174
1 parent 97229d3
commit e8b1174
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 19 deletions.
diff --git a/internal/resource/observer/observer_flow.go b/internal/resource/observer/observer_flow.go
@@ -75,7 +75,7 @@ func genRecoverOBServerFlow(_ *OBServerManager) *tasktypes.TaskFlow {
 	return &tasktypes.TaskFlow{
 		OperationContext: &tasktypes.OperationContext{
 			Name:         fRecoverOBServer,
-			Tasks:        []tasktypes.TaskName{tCreateOBPod, tWaitOBServerReady, tWaitOBServerActiveInCluster},
+			Tasks:        []tasktypes.TaskName{tCreateOBPod, tWaitOBServerReady, tAddServer, tWaitOBServerActiveInCluster},
 			TargetStatus: serverstatus.Running,
 			OnFailure: tasktypes.FailureRule{
 				Strategy: strategy.RetryFromCurrent,
@@ -84,16 +84,6 @@ func genRecoverOBServerFlow(_ *OBServerManager) *tasktypes.TaskFlow {
 	}
 }
 
-func genAddServerInOBFlow(_ *OBServerManager) *tasktypes.TaskFlow {
-	return &tasktypes.TaskFlow{
-		OperationContext: &tasktypes.OperationContext{
-			Name:         fAddServerInOB,
-			Tasks:        []tasktypes.TaskName{tAddServer, tWaitOBServerActiveInCluster},
-			TargetStatus: serverstatus.Running,
-		},
-	}
-}
-
 func genAnnotateOBServerPodFlow(_ *OBServerManager) *tasktypes.TaskFlow {
 	return &tasktypes.TaskFlow{
 		OperationContext: &tasktypes.OperationContext{

diff --git a/internal/resource/observer/observer_manager.go b/internal/resource/observer/observer_manager.go
@@ -113,12 +113,7 @@ func (m *OBServerManager) UpdateStatus() error {
 		// 1. Check status of observer in OB database
 		if m.OBServer.Status.Status == serverstatus.Running {
 			m.Logger.V(oceanbaseconst.LogLevelDebug).Info("Check observer in obcluster")
-			observer, err := m.getCurrentOBServerFromOB()
-			if err != nil {
-				m.Logger.V(oceanbaseconst.LogLevelDebug).Info("Get observer failed, check next time")
-			} else if observer == nil {
-				m.OBServer.Status.Status = serverstatus.AddServer
-			} else if mode, exist := resourceutils.GetAnnotationField(m.OBServer, oceanbaseconst.AnnotationsMode); exist && mode == oceanbaseconst.ModeStandalone {
+			if mode, exist := resourceutils.GetAnnotationField(m.OBServer, oceanbaseconst.AnnotationsMode); exist && mode == oceanbaseconst.ModeStandalone {
 				if pod.Spec.Containers[0].Resources.Limits.Cpu().Cmp(m.OBServer.Spec.OBServerTemplate.Resource.Cpu) != 0 ||
 					pod.Spec.Containers[0].Resources.Limits.Memory().Cmp(m.OBServer.Spec.OBServerTemplate.Resource.Memory) != 0 {
 					m.OBServer.Status.Status = serverstatus.ScaleUp
@@ -228,8 +223,6 @@ func (m *OBServerManager) GetTaskFlow() (*tasktypes.TaskFlow, error) {
 		taskFlow = genRecoverOBServerFlow(m)
 	case serverstatus.Annotate:
 		taskFlow = genAnnotateOBServerPodFlow(m)
-	case serverstatus.AddServer:
-		taskFlow = genAddServerInOBFlow(m)
 	case serverstatus.ScaleUp:
 		taskFlow = genScaleUpOBServerFlow(m)
 	case serverstatus.ExpandPVC: