luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(leases): robustify lease coordinator shutdown

Browse source
This commit is contained in:
bencvdb 2021-07-07 14:30:36 -07:00
parent 69077e1fe2
commit 71653df306
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/leases/impl/LeaseCoordinator.java vendored
View file

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