This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 67bcf1e Merge pull request #15973 from
mosche/BEAM-13233-aws2-list-shards
add cd74e9f [BEAM-13443] Avoid blocking put to Kinesis records queue to
shutdown readers faster
add cdc9065 Merge pull request #16286: [BEAM-13443] Avoid blocking put to
Kinesis records queue to shutdown readers faster
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/io/aws2/kinesis/ShardReadersPool.java | 16 +++++++++++++---
.../org/apache/beam/sdk/io/kinesis/ShardReadersPool.java | 16 +++++++++++++---
2 files changed, 26 insertions(+), 6 deletions(-)
