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 cd50229 [FLINK-20928] Fix flaky test by retrying
notifyCheckpointComplete until either commit success or timeout
add ade011e [FLINK-24405][tests] Introduce util to reliably drain all
messages from a kafka topic
add 0a2325c [FLINK-24405][tests] Harden kafka tests based on KafkaTestBase
No new revisions were added by this update.
Summary of changes:
.../connector/kafka/sink/KafkaSinkITCase.java | 34 ++----
.../connector/kafka/sink/KafkaTransactionLog.java | 60 +---------
.../flink/connector/kafka/sink/KafkaUtil.java | 131 +++++++++++++++++++++
.../connector/kafka/sink/KafkaWriterITCase.java | 8 +-
.../connectors/kafka/FlinkKafkaProducerITCase.java | 19 ++-
.../connectors/kafka/KafkaMigrationTestBase.java | 2 +-
.../connectors/kafka/KafkaProducerTestBase.java | 3 +-
.../streaming/connectors/kafka/KafkaTestBase.java | 45 ++-----
.../connectors/kafka/KafkaTestEnvironment.java | 2 +-
.../connectors/kafka/KafkaTestEnvironmentImpl.java | 36 +-----
.../kafka/shuffle/KafkaShuffleITCase.java | 21 ++--
11 files changed, 194 insertions(+), 167 deletions(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
