This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 7df835b899d [HUDI-8868] Use external spillable map for
cachedAllInputFileSlices in BaseHoodieTableFileIndex (#12647)
add cb32e5e1bac [HUDI-8126] Use union to parallelize data and error table
writes (#12813)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/config/HoodieErrorTableConfig.java | 7 ++
.../hudi/config/TestHoodieErrorTableConfig.java | 33 +++--
.../utilities/streamer/BaseErrorTableWriter.java | 5 +
.../apache/hudi/utilities/streamer/StreamSync.java | 42 +++++--
.../deltastreamer/HoodieDeltaStreamerTestBase.java | 18 ++-
...TestHoodieDeltaStreamerErrorTableWriteFlow.java | 133 +++++++++++++++++++++
...TestHoodieDeltaStreamerSchemaEvolutionBase.java | 48 +++++++-
...oodieDeltaStreamerSchemaEvolutionExtensive.java | 83 ++++++++++---
.../utilities/sources/TestJsonKafkaSource.java | 11 ++
9 files changed, 343 insertions(+), 37 deletions(-)
copy
hudi-common/src/test/java/org/apache/hudi/common/util/TestHoodieTimer.java =>
hudi-client/hudi-client-common/src/test/java/org/apache/hudi/config/TestHoodieErrorTableConfig.java
(51%)
create mode 100644
hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerErrorTableWriteFlow.java
