[flink] branch master updated (34acdf1 -> 49d9092)

[ar...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 34acdf1  [hotfix][docs] Correct the examples in Python DataStream API
     add 442dc76  [FLINK-17170][kinesis] Move KinesaliteContainer to flink-connector-kinesis.
     add 49d9092  [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

No new revisions were added by this update.

Summary of changes:
 flink-connectors/flink-connector-kinesis/pom.xml   |  19 +++
 .../connectors/kinesis/FlinkKinesisConsumer.java   |   5 +-
 .../connectors/kinesis/FlinkKinesisITCase.java     | 157 +++++++++++++++++++++
 .../kinesis/testutils/KinesaliteContainer.java     | 137 ++++++++++++++++++
 .../flink-streaming-kinesis-test/pom.xml           |  16 +++
 .../kinesis/test/KinesisTableApiITCase.java        |  51 +++----
 .../test/containers/KinesaliteContainer.java       |  52 -------
 .../resources}/filter-large-orders.sql             |   0
 .../src/test/resources/log4j2-test.properties      |   2 +-
 9 files changed, 353 insertions(+), 86 deletions(-)
 create mode 100644 flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisITCase.java
 create mode 100644 flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/KinesaliteContainer.java
 delete mode 100644 flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/java/org/apache/flink/streaming/kinesis/test/containers/KinesaliteContainer.java
 rename flink-end-to-end-tests/flink-streaming-kinesis-test/src/{main/resources/org/apache/flink/streaming/kinesis/test => test/resources}/filter-large-orders.sql (100%)
 copy {flink-connectors/flink-connector-cassandra => flink-end-to-end-tests/flink-streaming-kinesis-test}/src/test/resources/log4j2-test.properties (98%)