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 9595767 [FLINK-24382][metrics] Do not compute recordsOut metric in
SinkOperator to allow sinks emitting a flexible number of records
add cd50229 [FLINK-20928] Fix flaky test by retrying
notifyCheckpointComplete until either commit success or timeout
No new revisions were added by this update.
Summary of changes:
.../kafka/source/reader/KafkaSourceReader.java | 13 ++++++++++---
.../kafka/source/reader/KafkaSourceReaderTest.java | 20 +++++++++++++++-----
.../flink/core/testutils/CommonTestUtils.java | 21 +++++++++++++++++++--
3 files changed, 44 insertions(+), 10 deletions(-)
