From 3b2451bc45379ccba87a310eff63a5805ee449bd Mon Sep 17 00:00:00 2001 From: Alok Kumar Singh Date: Fri, 19 Mar 2021 07:14:55 +0530 Subject: [PATCH] More safety check --- controllers/redshiftsink_controller.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/controllers/redshiftsink_controller.go b/controllers/redshiftsink_controller.go index 0f181e014..162619838 100644 --- 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