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/01/27 08:51:12 UTC
[flink] branch master updated (5c2ec72 -> 9df1980)
This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5c2ec72 [FLINK-25035][runtime] SingleInputGate supports consuming subpartition range
add 9df1980 [FLINK-25810][connector/kinesis] Adding Kinesis data streams SQL client uber jar and end to end test.
No new revisions were added by this update.
Summary of changes:
.../pom.xml | 118 +++++++++
.../src/main/resources/META-INF/NOTICE | 49 ++++
flink-connectors/pom.xml | 1 +
.../flink-end-to-end-tests-kinesis-streams/pom.xml | 117 +++++++++
.../table/test/KinesisDataStreamsTableApiIT.java | 265 +++++++++++++++++++++
.../src/test/resources/log4j2-test.properties | 0
.../src/test/resources/send-orders.sql} | 18 +-
flink-end-to-end-tests/pom.xml | 1 +
8 files changed, 552 insertions(+), 17 deletions(-)
create mode 100644 flink-connectors/flink-sql-connector-aws-kinesis-data-streams/pom.xml
create mode 100644 flink-connectors/flink-sql-connector-aws-kinesis-data-streams/src/main/resources/META-INF/NOTICE
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-kinesis-streams/pom.xml
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/table/test/KinesisDataStreamsTableApiIT.java
copy flink-end-to-end-tests/{flink-streaming-kinesis-test => flink-end-to-end-tests-kinesis-streams}/src/test/resources/log4j2-test.properties (100%)
copy flink-end-to-end-tests/{flink-streaming-kinesis-test/src/test/resources/filter-large-orders.sql => flink-end-to-end-tests-kinesis-streams/src/test/resources/send-orders.sql} (71%)