This is an automated email from the ASF dual-hosted git repository.
yihua pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 1c4d44658da [HUDI-9079] Log the exception message properly to handle
the 'default' partition value migration steps (#12911)
add 82640aef626 [HUDI-9092] Deprecate byte array of serialization of
instants (#12900)
No new revisions were added by this update.
Summary of changes:
.../hudi/cli/commands/TestCompactionCommand.java | 4 +-
.../HoodieTestCommitMetadataGenerator.java | 11 +-
.../cli/testutils/HoodieTestCommitUtilities.java | 4 +-
.../hudi/client/BaseHoodieTableServiceClient.java | 4 +-
.../apache/hudi/client/BaseHoodieWriteClient.java | 8 +-
.../apache/hudi/client/CompactionAdminClient.java | 6 +-
.../utils/LegacyArchivedMetaEntryReader.java | 3 +-
.../index/bucket/ConsistentBucketIndexUtils.java | 4 +-
.../table/action/clean/CleanActionExecutor.java | 9 +-
.../action/clean/CleanPlanActionExecutor.java | 7 +-
.../cluster/ClusteringPlanActionExecutor.java | 20 +-
.../action/commit/BaseCommitActionExecutor.java | 13 +-
.../hudi/table/action/compact/CompactHelpers.java | 13 +-
.../compact/ScheduleCompactionActionExecutor.java | 24 +--
.../table/action/index/RunIndexActionExecutor.java | 5 +-
.../action/index/ScheduleIndexActionExecutor.java | 7 +-
.../action/restore/BaseRestoreActionExecutor.java | 2 +-
.../rollback/BaseRollbackActionExecutor.java | 5 +-
.../rollback/BaseRollbackPlanActionExecutor.java | 8 +-
.../action/rollback/RestorePlanActionExecutor.java | 8 +-
.../action/savepoint/SavepointActionExecutor.java | 6 +-
.../upgrade/EightToSevenDowngradeHandler.java | 11 +-
.../table/upgrade/SevenToEightUpgradeHandler.java | 3 +-
.../org/apache/hudi/HoodieTestCommitGenerator.java | 12 +-
.../timeline/TestCompletionTimeQueryView.java | 6 +-
.../TestConflictResolutionStrategyUtil.java | 4 +-
.../table/timeline/TestArchivedTimelineV2.java | 3 +-
.../common/testutils/HoodieMetadataTestTable.java | 5 +-
.../hudi/utils/TestMetadataConversionUtils.java | 2 +-
.../hudi/client/HoodieFlinkTableServiceClient.java | 8 +-
.../FlinkDeletePartitionCommitActionExecutor.java | 3 +-
.../SparkDeletePartitionCommitActionExecutor.java | 4 +-
.../functional/TestExternalPathHandling.java | 7 +-
.../TestHoodieClientOnCopyOnWriteStorage.java | 5 +-
.../apache/hudi/io/TestHoodieTimelineArchiver.java | 16 +-
.../clean/TestCleanerInsertAndCleanByVersions.java | 3 +-
.../table/functional/TestCleanActionExecutor.java | 4 +-
.../table/functional/TestCleanPlanExecutor.java | 3 +-
.../hudi/testutils/HoodieCleanerTestBase.java | 5 +-
hudi-common/pom.xml | 1 -
.../hudi/common/table/HoodieTableMetaClient.java | 23 +--
.../common/table/timeline/CommitMetadataSerDe.java | 22 ++-
.../table/timeline/HoodieActiveTimeline.java | 125 ++++++-------
.../hudi/common/table/timeline/HoodieTimeline.java | 9 +
.../table/timeline/MetadataConversionUtils.java | 51 +++--
.../table/timeline/TimelineMetadataUtils.java | 70 ++-----
.../hudi/common/table/timeline/TimelineUtils.java | 12 ++
.../timeline/versioning/v1/ActiveTimelineV1.java | 175 ++++++++---------
.../versioning/v1/CommitMetadataSerDeV1.java | 25 ++-
.../timeline/versioning/v2/ActiveTimelineV2.java | 193 +++++++++----------
.../versioning/v2/CommitMetadataSerDeV2.java | 26 +--
.../apache/hudi/common/util/ClusteringUtils.java | 17 +-
.../io/FileBasedInternalSchemaStorageManager.java | 6 +-
.../common/model/TestHoodieCommitMetadata.java | 3 +-
.../versioning/BaseTestCommitMetadataSerDe.java | 23 +--
.../versioning/v2/TestCommitMetadataSerDeV2.java | 8 +-
.../hudi/common/testutils/CompactionTestUtils.java | 3 +-
.../hudi/common/testutils/FileCreateUtils.java | 106 ++++++-----
.../common/testutils/FileCreateUtilsLegacy.java | 64 +++----
.../common/testutils/HoodieTestDataGenerator.java | 17 +-
.../hudi/common/testutils/HoodieTestUtils.java | 5 +
.../hudi/source/TestIncrementalInputSplits.java | 16 +-
.../org/apache/hudi/utils/TestClusteringUtil.java | 15 +-
.../org/apache/hudi/utils/TestCompactionUtil.java | 11 +-
.../test/java/org/apache/hudi/utils/TestUtils.java | 6 +-
.../common/table/TestHoodieTableMetaClient.java | 23 +--
.../hudi/common/table/TestTableSchemaResolver.java | 16 +-
.../hudi/common/table/TestTimelineUtils.java | 47 +++--
.../table/timeline/TestHoodieActiveTimeline.java | 10 +-
.../view/TestHoodieTableFSViewWithClustering.java | 12 +-
.../table/view/TestHoodieTableFileSystemView.java | 206 +++++++++------------
.../table/view/TestIncrementalFSViewSync.java | 28 ++-
.../common/testutils/HoodieCommonTestHarness.java | 7 +-
.../hudi/common/testutils/HoodieTestTable.java | 25 ++-
.../hudi/common/util/TestClusteringUtils.java | 34 ++--
.../apache/hudi/common/util/TestCommitUtils.java | 19 +-
.../hudi/hadoop/TestHoodieHFileInputFormat.java | 19 +-
.../hudi/hadoop/TestHoodieParquetInputFormat.java | 19 +-
.../realtime/TestHoodieRealtimeRecordReader.java | 27 ++-
.../org/apache/hudi/common/util/FileIOUtils.java | 4 +-
.../timeline/HoodieMetaserverBasedTimeline.java | 19 +-
.../AlterHoodieTableAddColumnsCommand.scala | 5 +-
.../benchmark/LSMTimelineReadBenchmark.scala | 6 +-
.../apache/spark/sql/hudi/ddl/TestAlterTable.scala | 3 +-
.../spark/sql/hudi/command/AlterTableCommand.scala | 3 +-
.../hudi/hive/testutils/HiveTestCluster.java | 8 +-
.../apache/hudi/hive/testutils/HiveTestUtil.java | 28 +--
.../deltastreamer/HoodieDeltaStreamerTestBase.java | 13 +-
.../utilities/sources/TestHoodieIncrSource.java | 5 +-
.../streamer/TestStreamerCheckpointUtils.java | 6 +-
90 files changed, 853 insertions(+), 1046 deletions(-)