This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 543e885 [FLINK-26592][state/changelog] Use mailbox in
FsStateChangelogWriter instead of a lock
new c336b84 [FLINK-26420][File] use numRecordsSendCounter from
SinkWriterMetricGroup directly.
new 4aec117 [FLINK-26420][Connector-base] use numRecordsSendCounter from
SinkWriterMetricGroup directly.
new 06b2b1d [FLINK-26420][test] migrate FileWriterTest to AssertJ.
new 71ee033 [FLINK-26420][test] migrate AsyncSinkWriterTest to AssertJ.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../base/sink/writer/AsyncSinkWriter.java | 12 +-
.../base/sink/writer/AsyncSinkWriterTest.java | 224 ++++++++++++---------
.../base/sink/writer/TestSinkInitContext.java | 4 +-
.../connector/file/sink/writer/FileWriter.java | 7 +-
.../connector/file/sink/writer/FileWriterTest.java | 176 ++++++++--------
5 files changed, 237 insertions(+), 186 deletions(-)
