This is an automated email from the ASF dual-hosted git repository.
voonhous pushed a change to branch release-1.2.1
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 73ec4812c2f6 fix: Isolate classloader-aware parallel execution in
HoodiePreCommitValidatorEngineContext (#18585)
new df35de41ee78 perf(spark): Resolve drop-partition-columns projection
once per writer instead of per row (#18972)
new 87b86fef303d fix(spark): strip _hoodie_* meta columns from CDC
before/after images (#18948)
new fc56bedbaf2c perf(spark): Parse bucket index hash-field config once
instead of per… (#18979)
new 1588e027e91d perf(metadata): Parse RLI instant time once per batch
instead of per … (#18965)
new 23d50905d6e8 test(trino): de-flake TestHudi*FileOperations by
disabling async table statistics (#18995)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../metadata/HoodieBackedTableMetadataWriter.java | 4 +-
.../apache/hudi/metadata/RecordIndexMapper.java | 9 ++-
...SparkJobConsistentHashingExecutionStrategy.java | 9 ++-
...ntBucketIndexBulkInsertPartitionerWithRows.java | 9 ++-
.../BucketBulkInsertDataInternalWriterHelper.java | 11 +++-
.../commit/BulkInsertDataInternalWriterHelper.java | 64 ++++++++++++++++------
...ntBucketBulkInsertDataInternalWriterHelper.java | 2 +-
.../action/commit/SparkBucketIndexPartitioner.java | 9 ++-
.../SparkPartitionBucketIndexPartitioner.java | 9 ++-
.../apache/spark/sql/BucketPartitionUtils.scala | 6 +-
.../hudi/metadata/BaseFileRecordParsingUtils.java | 3 +-
.../hudi/metadata/HoodieMetadataPayload.java | 42 ++++++++++++--
.../hudi/metadata/HoodieTableMetadataUtil.java | 10 +++-
.../hudi/metadata/TestHoodieTableMetadataUtil.java | 58 ++++++++++++++++++++
.../hudi/sink/partitioner/index/IndexRowUtils.java | 4 +-
.../sink/partitioner/index/IndexWriteFunction.java | 4 +-
.../org/apache/hudi/cdc/CDCFileGroupIterator.scala | 22 ++++++--
.../functional/cdc/TestCDCDataFrameSuite.scala | 61 +++++++++++++++++++++
.../hudi/TestHudiAlluxioCacheFileOperations.java | 48 ++++------------
.../hudi/TestHudiMemoryCacheFileOperations.java | 48 ++++------------
.../plugin/hudi/TestHudiNoCacheFileOperations.java | 48 ++++------------
21 files changed, 319 insertions(+), 161 deletions(-)
