From 5a0a6c600e80d39d81764be4fb7579faf45f8a6a Mon Sep 17 00:00:00 2001
From: Joshua Kim <kimjos@amazon.com>
Date: Mon, 27 Jul 2020 18:08:35 -0400
Subject: [PATCH] Adding safety check around stopwatches

---
 .../amazon/kinesis/leases/LeaseCleanupManager.java       | 9 ++++++---
 1 file changed, 6 insertions(+), 3 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 4e43c638..0feb25e6 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
@@ -82,12 +82,15 @@ public class LeaseCleanupManager {
      */
     public void start() {
         log.debug("Starting lease cleanup thread.");
-        isRunning = true;
-        completedLeaseStopwatch.start();
-        garbageLeaseStopwatch.start();
+
+        if (!isRunning) {
+            completedLeaseStopwatch.start();
+            garbageLeaseStopwatch.start();
+        }
 
         deletionThreadPool.scheduleAtFixedRate(new LeaseCleanupThread(), INITIAL_DELAY, leaseCleanupIntervalMillis,
                 TimeUnit.MILLISECONDS);
+        isRunning = true;
     }
 
     /**