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();