This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 832d412 [FLINK-25067][doc] Correct the description of RocksDB's
background threads for flush and compaction
add cb5034b [FLINK-24227][connectors] Introduced maxRecordSizeInBytes and
changed the behaviour of flushOnBufferSizeInBytes, renamed all instances of
flushOnBufferSizeInBytes to maxBatchSizeInBytes to reflect the new behaviour of
this parameter (#17913)
No new revisions were added by this update.
Summary of changes:
.../flink/connector/base/sink/AsyncSinkBase.java | 19 ++-
.../connector/base/sink/AsyncSinkBaseBuilder.java | 31 +++-
.../base/sink/writer/AsyncSinkWriter.java | 66 ++++++---
.../connector/base/sink/ArrayListAsyncSink.java | 17 ++-
.../connector/base/sink/AsyncSinkBaseITCase.java | 2 +-
.../base/sink/writer/AsyncSinkWriterTest.java | 156 ++++++++++++++++-----
6 files changed, 215 insertions(+), 76 deletions(-)
