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

Merge pull request #9 from fivetran/robust-shutdown

Browse source 
fix(leases): robustify lease coordinator shutdown
This commit is contained in:
bencvdb 2021-07-07 15:17:10 -07:00 committed by GitHub
commit 5bed718bc4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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. * Requests the cancellation of the lease taker.
*/ */
public void stopLeaseTaker() { public void stopLeaseTaker() {
takerFuture.cancel(false); if (takerFuture != null) takerFuture.cancel(false);
} }