More safety check

practo · Mar 19, 2021 · 3b2451b · 3b2451b
1 parent b06fa03
commit 3b2451b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/controllers/redshiftsink_controller.go b/controllers/redshiftsink_controller.go
@@ -411,6 +411,9 @@ func (r *RedshiftSinkReconciler) reconcile(
 			klog.Fatalf("rsk/%s unexpected status, released=0", rsk.Name)
 		}
 	}
+	if len(status.diffTopics) == 0 && len(status.reloading) > 0 {
+		klog.Fatalf("rsk/%s unexpected status, no diff but reloading", rsk.Name)
+	}
 
 	// SinkGroup are of following types:
 	// 1. main: sink group which has desiredMaskVersion