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

Posted to commits@flink.apache.org by fp...@apache.org on 2022/02/25 15:46:48 UTC

[flink] branch master updated (66af14b -> 5c6a220)

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

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


    from 66af14b  [FLINK-26287][table] Update some test classes for the new TableConfig.set
     add d4258b7  [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer
     add fe9e13f  [FLINK-26143][connector/kafka] Temporarily disable FlinkKafkaProducerITCase.testFlinkKafkaProducerFailBeforeNotify because it hangs in IDE and CI
     add 5c6a220  [FLINK-25249][connector/kafka] Use 1 broker in Kafka tests to reduce complexity of environment

No new revisions were added by this update.

Summary of changes:
 .../flink/connector/kafka/testutils/KafkaUtil.java |  17 +-
 .../kafka/FlinkKafkaInternalProducerITCase.java    |  31 +-
 .../connectors/kafka/FlinkKafkaProducerITCase.java |  31 +-
 .../connectors/kafka/KafkaConsumerTestBase.java    |  79 ++---
 .../streaming/connectors/kafka/KafkaTestBase.java  |   2 +-
 .../connectors/kafka/KafkaTestEnvironment.java     |   7 +-
 .../connectors/kafka/KafkaTestEnvironmentImpl.java | 363 +++++++++++----------
 .../org/apache/flink/util/DockerImageVersions.java |   2 +
 8 files changed, 235 insertions(+), 297 deletions(-)