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 aa10d88 [FLINK-29907][Connectors/AWS] Fix NOTICE file for Firehose
SQL connector
new 79f627a [FLINK-29908][Connectors/Firehose] Externalize and configure
E2E tests for Firehose connectors
new d9a3b05 [FLINK-29908][Connectors/Firehose] Externalize and configure
E2E tests for Kinesis connector v2
new 861b8d7 [FLINK-29908][Connectors/Firehose] Externalize and configure
E2E tests for Kinesis connector
new df4e3d3 [FLINK-29908] Adding e2e tests CI step
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/ci.yml | 37 ++-
flink-connector-aws-e2e-tests/README.md | 14 ++
.../pom.xml | 136 +++++++++++
.../table/test/KinesisFirehoseTableITTest.java | 257 +++++++++++++++++++
.../src/test/resources/log4j2-test.properties | 1 -
.../src/test/resources/send-orders.sql | 36 +++
.../pom.xml | 125 ++++++++++
.../table/test/KinesisStreamsTableApiIT.java | 271 +++++++++++++++++++++
.../src/test/resources/log4j2-test.properties | 1 -
.../src/test/resources/send-orders.sql | 36 +++
.../flink-connector-kinesis-e2e-tests/pom.xml | 177 ++++++++++++++
.../kinesis/test/CustomWatermarkExtractor.java | 53 ++++
.../apache/flink/streaming/kinesis/test/Event.java | 71 ++++++
.../flink/streaming/kinesis/test/EventSchema.java | 43 ++--
.../streaming/kinesis/test/KinesisExample.java | 102 ++++++++
.../streaming/kinesis/test/KinesisExampleTest.java | 122 ++++++++++
.../kinesis/test/RollingAdditionMapper.java | 55 +++++
.../kinesis/test/KinesisTableApiITCase.java | 184 ++++++++++++++
.../flink/streaming/kinesis/test/model/Order.java | 65 +++++
.../src/test/resources/filter-large-orders.sql | 52 ++++
.../src/test/resources/log4j2-test.properties | 1 -
flink-connector-aws-e2e-tests/pom.xml | 124 ++++++++++
pom.xml | 8 +-
23 files changed, 1940 insertions(+), 31 deletions(-)
create mode 100644 flink-connector-aws-e2e-tests/README.md
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-firehose-e2e-tests/pom.xml
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-firehose-e2e-tests/src/test/java/org/apache/flink/connector/firehose/table/test/KinesisFirehoseTableITTest.java
copy {flink-connector-dynamodb =>
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-firehose-e2e-tests}/src/test/resources/log4j2-test.properties
(99%)
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-firehose-e2e-tests/src/test/resources/send-orders.sql
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests/pom.xml
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests/src/test/java/org/apache/flink/connector/kinesis/table/test/KinesisStreamsTableApiIT.java
copy {flink-connector-dynamodb =>
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests}/src/test/resources/log4j2-test.properties
(99%)
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests/src/test/resources/send-orders.sql
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/pom.xml
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/CustomWatermarkExtractor.java
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/Event.java
copy
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/DynamoDBStreamsSchema.java
=>
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/EventSchema.java
(50%)
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/KinesisExample.java
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/KinesisExampleTest.java
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/RollingAdditionMapper.java
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/test/java/org/apache/flink/streaming/kinesis/test/KinesisTableApiITCase.java
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/test/java/org/apache/flink/streaming/kinesis/test/model/Order.java
create mode 100644
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/test/resources/filter-large-orders.sql
copy {flink-connector-dynamodb =>
flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests}/src/test/resources/log4j2-test.properties
(99%)
create mode 100644 flink-connector-aws-e2e-tests/pom.xml
