This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 2a404f0dea [hotfix] Fix NPE in ColumnarRowIterator.reset
add 6cffdef90f [cdc] Add option to prevent logging of corrupted records
(#4918)
No new revisions were added by this update.
Summary of changes:
.../sink/cdc/CdcDynamicBucketWriteOperator.java | 18 +++++++++++++----
.../sink/cdc/CdcRecordStoreMultiWriteOperator.java | 16 +++++++++++----
.../sink/cdc/CdcRecordStoreWriteOperator.java | 23 ++++++++++++++++++----
.../paimon/flink/sink/cdc/CdcRecordUtils.java | 6 ++++--
4 files changed, 49 insertions(+), 14 deletions(-)
