fix

confluentinc · Jan 11, 2024 · dc5f766 · dc5f766
1 parent 5e59883
commit dc5f766
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/controllers/druid/drain_historical.go b/controllers/druid/drain_historical.go
@@ -70,6 +70,9 @@ func scaleStatefulSet(sdk client.Client, m *v1alpha1.Druid, nodeSpec *v1alpha1.D
 }
 
 func deployHistorical(sdk client.Client, m *v1alpha1.Druid, nodeSpec *v1alpha1.DruidNodeSpec, nodeSpecUniqueStr string, emitEvent EventEmitter, batchSize int32, baseUrl string) error {
+ if batchSize <= 0 {
+ return fmt.Errorf("Invalid BatchSize supplied: %s", batchSize)
+ }
  // patch the updateStrategy with onDelete
  err := patchUpdateStrategy(sdk, m, nodeSpec, onDelete, emitEvent)
  if err != nil {