You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ar...@apache.org on 2021/05/06 14:09:19 UTC

[flink] branch release-1.12 updated (2691b8d -> 1de3d63)

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

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


    from 2691b8d  [FLINK-22557][build] Run japicmp against 1.12.2
     add 59f764b  [FLINK-22566][e2e] Disable Running Kerberized YARN application on Docker test (default input) fails with no resources
     add 1de3d63  [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 ++++++++++++++++++
 .../kinesis/testutils/KinesisPubsubClient.java     |   8 +-
 flink-end-to-end-tests/run-nightly-tests.sh        |   4 +-
 6 files changed, 324 insertions(+), 6 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