You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ar...@apache.org on 2022/01/03 17:19:01 UTC

[beam] 01/01: Merge pull request #16368: [BEAM-13509] Stop sharing SQS client between readers of same source.

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 <33...@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(-)