This is an automated email from the ASF dual-hosted git repository.
1996fanrui pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from 0caa1c9c [hotfix] Update Maven Wrapper
add 2d441987 [FLINK-39699][tests] Wait for completed checkpoint stats in
KafkaSinkITCase
add 443c0f32 [FLINK-39699][tests] Wait for partitions assignment in
KafkaSinkITCase
add 887d5941 [hotfix] Stabilize KafkaWriterFaultToleranceITCase
exception-on-unavailable tests
No new revisions were added by this update.
Summary of changes:
.../connector/kafka/sink/KafkaSinkITCase.java | 66 ++++++++++++----------
.../sink/KafkaWriterFaultToleranceITCase.java | 6 ++
2 files changed, 43 insertions(+), 29 deletions(-)
