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