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 2c5e7a4 [FLINK-24445][build] Copy rpc-akka jar in package phase
add 9595767 [FLINK-24382][metrics] Do not compute recordsOut metric in
SinkOperator to allow sinks emitting a flexible number of records
No new revisions were added by this update.
Summary of changes:
.../apache/flink/connector/file/sink/FileSink.java | 2 +
.../connector/file/sink/writer/FileWriter.java | 9 ++++
.../connector/file/sink/writer/FileWriterTest.java | 61 ++++++++++++++++++++--
.../flink/connector/kafka/sink/KafkaWriter.java | 3 ++
.../connector/kafka/sink/KafkaWriterITCase.java | 9 ++--
.../runtime/operators/sink/SinkOperator.java | 4 --
.../test/streaming/runtime/SinkMetricsITCase.java | 4 ++
7 files changed, 81 insertions(+), 11 deletions(-)
