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