From bc5dae270f249ec036bbbae1ccf824a15f7f1c94 Mon Sep 17 00:00:00 2001 From: Joshua Kim Date: Mon, 27 Jul 2020 17:58:39 -0400 Subject: [PATCH] Fixing bug where isRunning is not set --- .../java/software/amazon/kinesis/leases/LeaseCleanupManager.java | 1 + 1 file changed, 1 insertion(+) 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 de734646..4e43c638 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,6 +82,7 @@ public class LeaseCleanupManager { */ public void start() { log.debug("Starting lease cleanup thread."); + isRunning = true; completedLeaseStopwatch.start(); garbageLeaseStopwatch.start();