This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1d6aacf18176230f94efa3f7b6a82b9edcc088de
Merge: 7ef6560 cdf99be
Author: Alexey Romanenko <33895511+aromanenko-...@users.noreply.github.com>
AuthorDate: Wed Mar 23 11:37:19 2022 +0100
Merge pull request #17140: [BEAM-13232] Close clients properly in
KinesisSource.
.../beam/sdk/io/aws2/kinesis/KinesisReader.java | 10 ++-
.../beam/sdk/io/aws2/kinesis/KinesisSource.java | 30 +++++----
.../io/aws2/kinesis/SimplifiedKinesisClient.java | 75 ++++++++++++++++------
.../aws2/kinesis/SimplifiedKinesisClientTest.java | 47 ++++++++++----
4 files changed, 116 insertions(+), 46 deletions(-)
