This is an automated email from the ASF dual-hosted git repository.
zhangyue19921010 pushed a change to branch HUDI-8990-Part2
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 1610e8ca29b code review
add 93b4da301d1 [MINOR]Fix typo and Add implementation class name in
interface method of HoodieRecordMerger (#13059)
add 1f52b4e8b0e [HUDI-9206] Support reading inflight instants with
HoodieLogRecordReader (#13010)
add d33f95497b6 [HUDI-9252] BaseHoodieWriteClient should only check for
upgrade (#13073)
add e173216ecd0 [MINOR] Fix build error on master (#13075)
add c7c3532477a [MINOR] Remove warning around table version six (#13080)
add fbf852546d8 [MINOR] Fixing master for build failure (#13085)
add 76a8615fa91 [MINOR] Fix NumberFormatException while updating metrics
for MDT in table version 6 (#13056)
add 94f3c8082d4 Merge branch 'master' into HUDI-8990-Part2
add b53f457aa1e fix ut
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/client/BaseHoodieWriteClient.java | 10 +-
.../org/apache/hudi/config/HoodieWriteConfig.java | 5 -
...ieBackedTableMetadataWriterTableVersionSix.java | 6 ++
.../org/apache/hudi/metrics/HoodieMetrics.java | 4 +-
.../hudi/table/upgrade/UpgradeDowngrade.java | 13 ++-
.../apache/hudi/config/TestHoodieWriteConfig.java | 2 +-
.../org/apache/hudi/metrics/TestHoodieMetrics.java | 7 +-
.../MultipleSparkJobExecutionStrategy.java | 17 +---
...HoodieSparkFileGroupReaderBasedMergeHandle.java | 17 +---
.../hudi/table/upgrade/TestUpgradeDowngrade.java | 39 +++++++
.../hudi/common/model/HoodieRecordMerger.java | 4 +-
.../table/log/BaseHoodieLogRecordReader.java | 24 ++---
.../table/log/HoodieMergedLogRecordReader.java | 23 +++--
.../common/table/read/HoodieFileGroupReader.java | 25 +++--
.../hudi/metadata/HoodieTableMetadataUtil.java | 1 +
.../table/read/TestHoodieFileGroupReaderBase.java | 2 +
.../reader/HoodieFileGroupReaderTestUtils.java | 27 ++---
.../TestHoodieFileGroupReaderInflightCommit.java | 112 +++++++++++++++++++++
.../reader/HoodieFileGroupReaderTestHarness.java | 9 +-
.../HoodieFileGroupReaderBasedRecordReader.java | 2 +-
.../scala/org/apache/hudi/HoodieFileIndex.scala | 22 ++--
...odieFileGroupReaderBasedParquetFileFormat.scala | 16 +--
.../procedures/PartitionBucketIndexManager.scala | 3 +-
.../hudi/functional/TestStreamingSource.scala | 1 -
24 files changed, 263 insertions(+), 128 deletions(-)
create mode 100644
hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/read/TestHoodieFileGroupReaderInflightCommit.java
