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 c4fc3987f31a57a31d2081297fa639084b35d391
Merge: 2cd5013 0fd6504
Author: Alexey Romanenko <33895511+aromanenko-...@users.noreply.github.com>
AuthorDate: Mon Jan 3 18:17:42 2022 +0100
Merge pull request #16368: [BEAM-13509] Stop sharing SQS client between
readers of same source.
.../beam/sdk/io/aws/sqs/SqsUnboundedReader.java | 34 +++++++++++-----
.../beam/sdk/io/aws/sqs/SqsUnboundedSource.java | 20 +---------
.../sdk/io/aws/sqs/SqsUnboundedReaderTest.java | 2 +-
.../beam/sdk/io/aws2/sqs/SqsUnboundedReader.java | 45 ++++++++++++----------
.../beam/sdk/io/aws2/sqs/SqsUnboundedSource.java | 12 ------
.../sdk/io/aws2/sqs/SqsUnboundedReaderTest.java | 2 +-
6 files changed, 53 insertions(+), 62 deletions(-)
