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 737be25 [BEAM-13685] Enable users to specify cache directory under Interactive Beam options add 976b14c [BEAM-13653] Make SnsIO.write topicArn optional. If provided, validate it and force usage on the Sns publish request. add b521b3f Merge pull request #16503: [BEAM-13653] Fix usage of SnsIO.write topicArn (AWS Sdk v2) No new revisions were added by this update. Summary of changes: .../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 96 ++++++----- .../apache/beam/sdk/io/aws2/StaticSupplier.java} | 36 ++-- .../dynamodb/StaticDynamoDBClientProvider.java | 32 +--- .../beam/sdk/io/aws2/sns/SnsClientMockErrors.java | 52 ------ .../beam/sdk/io/aws2/sns/SnsClientMockSuccess.java | 58 ------- .../org/apache/beam/sdk/io/aws2/sns/SnsIOTest.java | 189 ++++++++++++++------- .../sdk/io/aws2/sns/StaticSnsClientProvider.java} | 21 ++- .../org/apache/beam/sdk/io/aws2/sqs/SqsIOTest.java | 2 +- .../sdk/io/aws2/sqs/SqsUnboundedReaderTest.java | 4 +- .../sdk/io/aws2/sqs/SqsUnboundedSourceTest.java | 2 +- ...viderMock.java => StaticSqsClientProvider.java} | 18 +- 11 files changed, 230 insertions(+), 280 deletions(-) copy sdks/java/{extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/testkit/accumulators/LongHistogram.java => io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/StaticSupplier.java} (53%) delete mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/SnsClientMockErrors.java delete mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/SnsClientMockSuccess.java copy sdks/java/io/amazon-web-services2/src/{main/java/org/apache/beam/sdk/io/aws2/sns/SnsClientProvider.java => test/java/org/apache/beam/sdk/io/aws2/sns/StaticSnsClientProvider.java} (66%) rename sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/{SqsClientProviderMock.java => StaticSqsClientProvider.java} (69%)