Skip to content

Sns migration to AWS Sdk V2 - first draft#1

Open
cmachgodaddy wants to merge 2 commits into
masterfrom
SNS-V2
Open

Sns migration to AWS Sdk V2 - first draft#1
cmachgodaddy wants to merge 2 commits into
masterfrom
SNS-V2

Conversation

@cmachgodaddy

Copy link
Copy Markdown
Owner

Please add a meaningful description for your change here


Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:

  • Choose reviewer(s) and mention them in a comment (R: @username).
  • Format the pull request title like [BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replace BEAM-XXX with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.
  • If this contribution is large, please file an Apache Individual Contributor License Agreement.

Post-Commit Tests Status (on master branch)

Lang SDK Apex Dataflow Flink Gearpump Samza Spark
Go Build Status --- --- Build Status --- --- Build Status
Java Build Status Build Status Build Status Build Status
Build Status
Build Status
Build Status Build Status Build Status
Build Status
Python [Build Status] (https://builds.apache.org/job/beam_PostCommit_Python2/lastCompletedBuild/)
[Build Status] (https://builds.apache.org/job/beam_PostCommit_Python35/lastCompletedBuild/)
[Build Status] (https://builds.apache.org/job/beam_PostCommit_Python36/lastCompletedBuild/)
[Build Status] (https://builds.apache.org/job/beam_PostCommit_Python37/lastCompletedBuild/)
--- Build Status
Build Status
Build Status --- --- Build Status

Pre-Commit Tests Status (on master branch)

--- Java Python Go Website
Non-portable Build Status Build Status Build Status Build Status
Portable --- Build Status --- ---

See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.

@iemejia iemejia left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looking good so far. Let some minor comments

import software.amazon.awssdk.services.sns.model.PublishResponse;

/** Custom Coder for handling publish result. */
public class PublishResultCoder extends Coder<PublishResponse> implements Serializable {

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

PublishResponseCoder better

kafka_clients : "org.apache.kafka:kafka-clients:$kafka_version",
malhar_library : "org.apache.apex:malhar-library:$apex_malhar_version",
mockito_core : "org.mockito:mockito-core:1.10.19",
mockito_core : "org.mockito:mockito-core:2.8.47",

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

don't change this one, do it in the AWS2 build gradle file and with version 2.3.0

cmachgodaddy pushed a commit that referenced this pull request Aug 21, 2019
It turned out we tested nothing relevant with the additional 2 tests
that are deleted. The Combine test maps values of different sizes to
Long value. The deleted tests had only different initial size so, in
practice, they were testing the same thing as test #1.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants