From 9c8b89e0c6a96390d507c59be23a1de688658a54 Mon Sep 17 00:00:00 2001
From: Joshua Kim <kimjos@amazon.com>
Date: Mon, 27 Jul 2020 18:14:11 -0400
Subject: [PATCH] Moving to after watches and executor initialized

---
 .../amazon/kinesis/leases/LeaseCleanupManager.java        | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java
index 0feb25e6..1d73c852 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java
@@ -83,10 +83,8 @@ public class LeaseCleanupManager {
     public void start() {
         log.debug("Starting lease cleanup thread.");
 
-        if (!isRunning) {
-            completedLeaseStopwatch.start();
-            garbageLeaseStopwatch.start();
-        }
+        completedLeaseStopwatch.start();
+        garbageLeaseStopwatch.start();
 
         deletionThreadPool.scheduleAtFixedRate(new LeaseCleanupThread(), INITIAL_DELAY, leaseCleanupIntervalMillis,
                 TimeUnit.MILLISECONDS);
@@ -138,7 +136,7 @@ public class LeaseCleanupManager {
     }
 
     public LeaseCleanupResult cleanupLease(LeasePendingDeletion leasePendingDeletion,
-            boolean timeToCheckForCompletedShard, boolean timeToCheckForGarbageShard) throws TimeoutException,
+                                           boolean timeToCheckForCompletedShard, boolean timeToCheckForGarbageShard) throws TimeoutException,
             InterruptedException, DependencyException, ProvisionedThroughputException, InvalidStateException {
         final Lease lease = leasePendingDeletion.lease();
         final ShardInfo shardInfo = leasePendingDeletion.shardInfo();