Parallel management by default for BE, CN, Broker statefulset

linsoss · Dec 20, 2023 · 59677a3 · 59677a3
1 parent 75eec5a
commit 59677a3
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 10 deletions.
diff --git a/internal/transformer/be_resources.go b/internal/transformer/be_resources.go
@@ -339,6 +339,7 @@ func MakeBeStatefulSet(cr *dapi.DorisCluster, scheme *runtime.Scheme) *appv1.Sta
 			VolumeClaimTemplates: pvcTemplates,
 			Template:             podTemplate,
 			UpdateStrategy:       updateStg,
+			PodManagementPolicy:  appv1.ParallelPodManagement,
 		},
 	}
 

diff --git a/internal/transformer/broker_resources.go b/internal/transformer/broker_resources.go
@@ -236,11 +236,12 @@ func MakeBrokerStatefulSet(cr *dapi.DorisCluster, scheme *runtime.Scheme) *appv1
 			Labels:    brokerLabels,
 		},
 		Spec: appv1.StatefulSetSpec{
-			Replicas:       &cr.Spec.Broker.Replicas,
-			ServiceName:    GetBrokerPeerServiceKey(cr.ObjKey()).Name,
-			Selector:       &metav1.LabelSelector{MatchLabels: brokerLabels},
-			Template:       podTemplate,
-			UpdateStrategy: updateStg,
+			Replicas:            &cr.Spec.Broker.Replicas,
+			ServiceName:         GetBrokerPeerServiceKey(cr.ObjKey()).Name,
+			Selector:            &metav1.LabelSelector{MatchLabels: brokerLabels},
+			Template:            podTemplate,
+			UpdateStrategy:      updateStg,
+			PodManagementPolicy: appv1.ParallelPodManagement,
 		},
 	}
 

diff --git a/internal/transformer/cn_resources.go b/internal/transformer/cn_resources.go
@@ -310,11 +310,12 @@ func MakeCnStatefulSet(cr *dapi.DorisCluster, scheme *runtime.Scheme) *appv1.Sta
 			Labels:    cnLabels,
 		},
 		Spec: appv1.StatefulSetSpec{
-			Replicas:       &cr.Spec.CN.Replicas,
-			ServiceName:    GetCnPeerServiceKey(cr.ObjKey()).Name,
-			Selector:       &metav1.LabelSelector{MatchLabels: cnLabels},
-			Template:       podTemplate,
-			UpdateStrategy: updateStg,
+			Replicas:            &cr.Spec.CN.Replicas,
+			ServiceName:         GetCnPeerServiceKey(cr.ObjKey()).Name,
+			Selector:            &metav1.LabelSelector{MatchLabels: cnLabels},
+			Template:            podTemplate,
+			UpdateStrategy:      updateStg,
+			PodManagementPolicy: appv1.ParallelPodManagement,
 		},
 	}