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 8adb095386e3 chore(api): declare the unstructured ingestion SPIs
evolving (#19701)
add 81fd4992b8dc fix(flink): prevent reusing diverged buffers on memory
exhaustion (#19692)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/sink/StreamWriteFunction.java | 178 ++++++++++++---
.../org/apache/hudi/sink/buffer/RowDataBucket.java | 10 +
.../TestBucketStreamWriteMemoryExhaustion.java | 243 +++++++++++++++++++++
.../apache/hudi/sink/buffer/TestRowDataBucket.java | 102 +++++++++
4 files changed, 497 insertions(+), 36 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/TestBucketStreamWriteMemoryExhaustion.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/buffer/TestRowDataBucket.java
