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 daa8ac9 [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to
complete before closing cluster
add 21fbd59e [FLINK-24612][connectors/kafka] Configure Kafka test
container log levels accordingly to test logger
No new revisions were added by this update.
Summary of changes:
.../sink/FlinkKafkaInternalProducerITCase.java | 11 ++----
.../connector/kafka/sink/KafkaSinkITCase.java | 15 ++------
.../kafka/sink/KafkaTransactionLogITCase.java | 16 ++------
.../flink/connector/kafka/sink/KafkaUtil.java | 43 ++++++++++++++++++++++
.../connector/kafka/sink/KafkaWriterITCase.java | 15 ++------
5 files changed, 55 insertions(+), 45 deletions(-)
