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%)