使用usebeta分组分组数+1

sofastack · Jan 3, 2024 · 815cf0d · 815cf0d
1 parent b82a9f2
commit 815cf0d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/module-controller/internal/controller/moduledeployment_controller.go b/module-controller/internal/controller/moduledeployment_controller.go
@@ -214,10 +214,13 @@ func handleInitModuleDeployment(moduleDeployment *v1alpha1.ModuleDeployment, new
 	)
 
 	batchCount := moduleDeployment.Spec.OperationStrategy.BatchCount
+	useBeta := moduleDeployment.Spec.OperationStrategy.UseBeta
 	if batchCount <= 0 {
 		realBatchCount = 1
 	} else if int32(math.Abs(float64(deltaReplicas))) < batchCount {
 		realBatchCount = int32(math.Abs(float64(deltaReplicas)))
+	} else if useBeta {
+		realBatchCount = batchCount + 1
 	} else {
 		realBatchCount = batchCount
 	}