This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 2f073643dfe7 feat: add graceful handling for post-commit failures with
metrics (#18196)
add 9859f9aa29df feat(flink): Support more efficient customized serializer
for HoodieRecordGlobalLocation (#18326)
No new revisions were added by this update.
Summary of changes:
.../hudi/common/util/collection/RocksDBDAO.java | 28 ++-
.../common/util/collection/TestRocksDBDAO.java | 39 +++++
.../sink/partitioner/BucketAssignFunction.java | 1 +
.../index/RecordGlobalLocationSerializer.java | 116 +++++++++++++
.../partitioner/index/RocksDBIndexBackend.java | 8 +-
.../index/TestRecordGlobalLocationSerializer.java | 191 +++++++++++++++++++++
.../partitioner/index/TestRocksDBIndexBackend.java | 5 +-
7 files changed, 378 insertions(+), 10 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/index/RecordGlobalLocationSerializer.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/partitioner/index/TestRecordGlobalLocationSerializer.java
