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(-)

Reply via email to