This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from c229ccf57ce [HUDI-6233] Fix table client conf in AlterTableCommand
(#8747)
add 4c980f3178a [HUDI-5238] Fix `HoodieMergeHandle` shutdown sequence
(#7245)
No new revisions were added by this update.
Summary of changes:
.../hudi/client/utils/ClosableMergingIterator.java | 20 ++++++----
.../apache/hudi/client/utils/MergingIterator.java | 22 +++++++----
.../org/apache/hudi/io/HoodieAppendHandle.java | 28 ++++++++------
.../org/apache/hudi/io/HoodieCreateHandle.java | 6 +++
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 12 ++++--
.../java/org/apache/hudi/io/HoodieWriteHandle.java | 10 +++++
.../action/bootstrap/BootstrapRecordConsumer.java | 1 +
.../hudi/table/action/commit/BaseMergeHelper.java | 1 +
.../table/action/commit/HoodieMergeHelper.java | 35 ++++++++---------
.../hudi/execution/FlinkLazyInsertIterable.java | 14 +++----
.../FlinkDeletePartitionCommitActionExecutor.java | 2 +-
.../hudi/execution/JavaLazyInsertIterable.java | 13 +++----
.../bootstrap/OrcBootstrapMetadataHandler.java | 23 ++++++-----
.../bootstrap/ParquetBootstrapMetadataHandler.java | 22 ++++++-----
.../TestBoundedInMemoryExecutorInSpark.java | 7 ++--
.../hudi/execution/TestDisruptorMessageQueue.java | 13 +------
.../table/log/HoodieMergedLogRecordScanner.java | 2 +-
.../org/apache/hudi/common/util/FutureUtils.java | 44 +++++++++++++++-------
.../org/apache/hudi/common/util/HoodieTimer.java | 9 ++++-
.../common/util/collection/ClosableIterator.java | 2 -
.../util/queue/BaseHoodieQueueBasedExecutor.java | 38 +++++++++++++++++--
.../common/util/queue/BoundedInMemoryQueue.java | 5 +++
.../common/util/queue/DisruptorMessageQueue.java | 8 ++++
.../hudi/common/util/queue/HoodieMessageQueue.java | 2 +
24 files changed, 220 insertions(+), 119 deletions(-)
copy
hudi-common/src/main/java/org/apache/hudi/common/util/collection/CloseableMappingIterator.java
=>
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/ClosableMergingIterator.java
(56%)
