diff --git a/cmd/main.go b/cmd/main.go
index c66d46e..1b1fa8d 100644
--- a/cmd/main.go
+++ b/cmd/main.go
@@ -46,15 +46,16 @@ import (
 )
 
 var (
-	setupLog             = ctrl.Log.WithName("setup")
-	metricsAddr          string
-	probeAddr            string
-	workers              int
-	restConfigQPS        float32
-	restConfigBurst      int
-	webhookPort          int
-	concurrentReconciles int
-	syncPeriod           time.Duration
+	setupLog              = ctrl.Log.WithName("setup")
+	metricsAddr           string
+	probeAddr             string
+	workers               int
+	restConfigQPS         float32
+	restConfigBurst       int
+	webhookPort           int
+	concurrentReconciles  int
+	syncPeriod            time.Duration
+	jitterWindowInSeconds int
 )
 
 func main() {
@@ -105,9 +106,10 @@ func main() {
 	}
 
 	if err = (&controller.CleanerReconciler{
-		Client:               mgr.GetClient(),
-		Scheme:               mgr.GetScheme(),
-		ConcurrentReconciles: concurrentReconciles,
+		Client:                mgr.GetClient(),
+		Scheme:                mgr.GetScheme(),
+		ConcurrentReconciles:  concurrentReconciles,
+		JitterWindowInSeconds: jitterWindowInSeconds,
 	}).SetupWithManager(ctx, mgr, workers, ctrl.Log.WithName("worker")); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "Cleaner")
 		os.Exit(1)
@@ -139,7 +141,11 @@ func initFlags(fs *pflag.FlagSet) {
 
 	const defaultWorkers = 5
 	fs.IntVar(&workers, "worker-number", defaultWorkers,
-		"Number of worker. Workers are used to process cleaner instances in backgroun")
+		"Number of worker. Workers are used to process cleaner instances in background")
+
+	const defaultJitterWindow = 15
+	fs.IntVar(&jitterWindowInSeconds, "jitter", defaultJitterWindow,
+		"The predefined time interval around a scheduled execution time.")
 
 	const defaultReconcilers = 10
 	fs.IntVar(&concurrentReconciles, "concurrent-reconciles", defaultReconcilers,
diff --git a/internal/controller/cleaner_controller.go b/internal/controller/cleaner_controller.go
index 21b11be..1da020b 100644
--- a/internal/controller/cleaner_controller.go
+++ b/internal/controller/cleaner_controller.go
@@ -44,8 +44,9 @@ import (
 // CleanerReconciler reconciles a Cleaner object
 type CleanerReconciler struct {
 	client.Client
-	Scheme               *runtime.Scheme
-	ConcurrentReconciles int
+	Scheme                *runtime.Scheme
+	ConcurrentReconciles  int
+	JitterWindowInSeconds int
 }
 
 //+kubebuilder:rbac:groups=apps.projectsveltos.io,resources=cleaners,verbs=get;list;watch;patch
@@ -151,7 +152,7 @@ func (r *CleanerReconciler) reconcileNormal(ctx context.Context, cleanerScope *s
 	}
 
 	now := time.Now()
-	nextRun, err := schedule(ctx, cleanerScope, logger)
+	nextRun, err := schedule(ctx, cleanerScope, r.JitterWindowInSeconds, logger)
 	if err != nil {
 		logger.Info("failed to get next run. Err: %v", err)
 		msg := err.Error()
@@ -216,7 +217,9 @@ func (r *CleanerReconciler) removeReport(ctx context.Context,
 	return fmt.Errorf("report instance still present")
 }
 
-func schedule(ctx context.Context, cleanerScope *scope.CleanerScope, logger logr.Logger) (*time.Time, error) {
+func schedule(ctx context.Context, cleanerScope *scope.CleanerScope, jitterWindowInSeconds int,
+	logger logr.Logger) (*time.Time, error) {
+
 	newLastRunTime := cleanerScope.Cleaner.Status.LastRunTime
 
 	now := time.Now()
@@ -231,7 +234,7 @@ func schedule(ctx context.Context, cleanerScope *scope.CleanerScope, logger logr
 		logger.Info("set NextScheduleTime")
 		newNextScheduleTime = &metav1.Time{Time: *nextRun}
 	} else {
-		if shouldSchedule(cleanerScope.Cleaner, logger) {
+		if shouldSchedule(cleanerScope.Cleaner, jitterWindowInSeconds, logger) {
 			logger.Info("queuing job")
 			executorClient := executor.GetClient()
 			executorClient.Process(ctx, cleanerScope.Cleaner.Name)
@@ -285,8 +288,9 @@ func getNextScheduleTime(cleaner *appsv1alpha1.Cleaner, now time.Time) (*time.Ti
 	return &next, nil
 }
 
-func shouldSchedule(cleaner *appsv1alpha1.Cleaner, logger logr.Logger) bool {
-	now := time.Now()
+func shouldSchedule(cleaner *appsv1alpha1.Cleaner, jitterWindowInSeconds int, logger logr.Logger) bool {
+	// if reconciliation is happening within jitterWindowInSeconds from scheduled time still process it
+	now := time.Now().Add(time.Duration(jitterWindowInSeconds) * time.Second)
 	logger.Info(fmt.Sprintf("currently next schedule is %s", cleaner.Status.NextScheduleTime.Time))
 
 	if now.Before(cleaner.Status.NextScheduleTime.Time) {