From 71653df306b40a2c77ed29602d8f2370426b3dcc Mon Sep 17 00:00:00 2001
From: bencvdb <bencvdb93#gmail.com>
Date: Wed, 7 Jul 2021 14:30:36 -0700
Subject: [PATCH] fix(leases): robustify lease coordinator shutdown

---
 .../services/kinesis/leases/impl/LeaseCoordinator.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/leases/impl/LeaseCoordinator.java b/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/leases/impl/LeaseCoordinator.java
index ef61c12c..425ff33a 100644
--- a/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/leases/impl/LeaseCoordinator.java
+++ b/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/leases/impl/LeaseCoordinator.java
@@ -322,7 +322,7 @@ public class LeaseCoordinator<T extends Lease> {
      * Requests the cancellation of the lease taker.
      */
     public void stopLeaseTaker() {
-        takerFuture.cancel(false);
+        if (takerFuture != null) takerFuture.cancel(false);
 
     }