From dc5f76626501a65ea7d04ed9b81daa9f0398cafe Mon Sep 17 00:00:00 2001
From: Rushikesh Bankar <rbankar@confluent.io>
Date: Thu, 11 Jan 2024 08:43:53 +0530
Subject: [PATCH] fix

---
 controllers/druid/drain_historical.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/controllers/druid/drain_historical.go b/controllers/druid/drain_historical.go
index c4d43e43..c7661824 100644
--- 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 {