You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by da...@apache.org on 2022/12/12 20:48:19 UTC
[flink-connector-aws] branch main updated (5768b29 -> d0817fe)
This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git
from 5768b29 [hotfix][docs] Fix shortcode reference
add d0817fe [FLINK-30384][Connector/AWS] Sync master KDS/KDF/Base connector changes to flink-connector-aws
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/datastream/kinesis.md | 4 +-
docs/content.zh/docs/connectors/table/firehose.md | 8 +++
docs/content.zh/docs/connectors/table/kinesis.md | 12 +++-
docs/content/docs/connectors/datastream/kinesis.md | 10 +--
docs/content/docs/connectors/table/firehose.md | 8 +++
docs/content/docs/connectors/table/kinesis.md | 12 +++-
.../connector/aws/config/AWSConfigConstants.java | 10 +++
.../flink/connector/aws/util/AWSGeneralUtil.java | 36 ++++++++---
.../connector/aws/util/AWSGeneralUtilTest.java | 31 +++++++++
.../table/test/KinesisFirehoseTableITTest.java | 2 +-
.../kinesis/testutils/KinesaliteContainer.java | 2 +-
flink-connector-kinesis/pom.xml | 42 ++++++++++++-
.../kinesis/internals/KinesisDataFetcher.java | 14 ++++-
.../streaming/connectors/kinesis/util/AWSUtil.java | 34 +++++++---
.../kinesis/util/JobManagerWatermarkTracker.java | 5 ++
.../src/main/resources/META-INF/NOTICE | 2 -
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 -
.../kinesis/FlinkKinesisConsumerTest.java | 8 +--
.../connectors/kinesis/testutils/TestUtils.java | 14 +++++
.../connectors/kinesis/util/AWSUtilTest.java | 73 ++++++++++++++++++++++
.../util/JobManagerWatermarkTrackerTest.java | 1 +
flink-sql-connector-kinesis/pom.xml | 29 ++++-----
.../src/main/resources/META-INF/NOTICE | 2 +-
pom.xml | 2 +-
24 files changed, 298 insertions(+), 66 deletions(-)