From b7a5d7968b813523ad44ab16345d297b6f655862 Mon Sep 17 00:00:00 2001
From: Joshua Kim <kimjos@amazon.com>
Date: Mon, 27 Jul 2020 19:31:52 -0400
Subject: [PATCH] Removing unnecessary code

---
 .../software/amazon/kinesis/coordinator/Scheduler.java     | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java
index db9cc145..ed2f889c 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java
@@ -348,12 +348,7 @@ public class Scheduler implements Runnable {
                         log.info("Skipping shard sync per configuration setting (and lease table is not empty)");
                     }
 
-                    if (!leaseCleanupManager.isRunning()) {
-                        log.info("Starting LeaseCleanupManager.");
-                        leaseCleanupManager.start();
-                    } else {
-                        log.info("LeaseCleanupManager is already running. No need to start it");
-                    }
+                    leaseCleanupManager.start();
 
                     // If we reach this point, then we either skipped the lease sync or did not have any exception
                     // for any of the shard sync in the previous attempt.