search

awslabs / amazon-kinesis-connector-flink

This is a fork of the Apache Flink Kinesis connector adding Enhanced Fanout support for Flink 1.8/1.11 on KDA.
Apache License 2.0
20 stars 11 forks source link

Fix issue where KinesisDataFetcher.shutdownFetcher() hangs #24

Closed GS-KeithLee closed 3 years ago

GS-KeithLee commented 3 years ago

Fix #23 An exception in KinesisDataFetcher#shutdownFetcher may fail to shutdown shardConsumersExecutor leading to job hanging

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.