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 999ff9c1095 [HUDI-8796] Restrict insert operation with bucket index
for Flink (#12545)
add 412f2b44242 [HUDI-8999] Improve usage of logging libraries (#12172)
No new revisions were added by this update.
Summary of changes:
.../hudi/aws/sync/AWSGlueCatalogSyncClient.java | 2 +-
.../apache/hudi/cli/commands/MetadataCommand.java | 6 ++--
.../hudi/cli/commands/TestCompactionCommand.java | 7 ++--
.../org/apache/hudi/async/AsyncCleanerService.java | 2 +-
.../org/apache/hudi/async/HoodieAsyncService.java | 2 +-
.../hudi/client/BaseHoodieTableServiceClient.java | 6 ++--
.../apache/hudi/client/BaseHoodieWriteClient.java | 22 ++++++------
.../java/org/apache/hudi/client/WriteStatus.java | 2 +-
.../hudi/client/heartbeat/HeartbeatUtils.java | 6 ++--
.../client/heartbeat/HoodieHeartbeatClient.java | 8 ++---
.../PreferWriterConflictResolutionStrategy.java | 4 +--
.../lock/BaseZookeeperBasedLockProvider.java | 6 ++--
...ZookeeperBasedImplicitBasePathLockProvider.java | 2 +-
.../org/apache/hudi/config/HoodieWriteConfig.java | 8 ++---
.../org/apache/hudi/index/HoodieIndexUtils.java | 8 ++---
.../apache/hudi/index/bloom/HoodieBloomIndex.java | 2 +-
.../org/apache/hudi/io/HoodieAppendHandle.java | 4 +--
.../org/apache/hudi/io/HoodieConcatHandle.java | 2 +-
.../org/apache/hudi/io/HoodieCreateHandle.java | 4 +--
.../org/apache/hudi/io/HoodieKeyLookupHandle.java | 15 +++-----
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 9 +++--
...ieBackedTableMetadataWriterTableVersionSix.java | 6 ++--
.../org/apache/hudi/metrics/HoodieMetrics.java | 8 ++---
.../java/org/apache/hudi/table/HoodieTable.java | 2 +-
.../table/action/clean/CleanActionExecutor.java | 6 ++--
.../action/clean/CleanPlanActionExecutor.java | 2 +-
.../hudi/table/action/clean/CleanPlanner.java | 6 ++--
.../compact/ScheduleCompactionActionExecutor.java | 14 ++++----
.../rollback/BaseRollbackActionExecutor.java | 4 +--
.../hudi/table/marker/WriteMarkersFactory.java | 4 +--
.../hudi/io/FlinkConcatAndReplaceHandle.java | 2 +-
.../java/org/apache/hudi/io/FlinkConcatHandle.java | 2 +-
.../commit/TestJavaCopyOnWriteActionExecutor.java | 1 -
.../hudi/client/HoodieSparkClusteringClient.java | 4 +--
.../apache/hudi/client/HoodieSparkCompactor.java | 4 +--
.../MultipleSparkJobExecutionStrategy.java | 2 +-
...SparkJobConsistentHashingExecutionStrategy.java | 2 +-
...onsistentBucketClusteringExecutionStrategy.java | 4 +--
.../SparkSingleFileSortExecutionStrategy.java | 4 +--
.../SparkSortAndSizeExecutionStrategy.java | 4 +--
.../hudi/client/utils/SparkValidatorUtils.java | 4 +--
.../HoodieMetadataBloomFilterProbingFunction.java | 4 +--
.../index/bloom/SparkHoodieBloomIndexHelper.java | 2 +-
.../apache/hudi/sort/SpaceCurveSortingHelper.java | 2 +-
.../BucketBulkInsertDataInternalWriterHelper.java | 4 +--
.../commit/BulkInsertDataInternalWriterHelper.java | 6 ++--
...ntBucketBulkInsertDataInternalWriterHelper.java | 2 +-
.../commit/SparkPartitionTTLActionExecutor.java | 2 +-
.../table/action/commit/UpsertPartitioner.java | 19 +++++-----
.../BaseSparkDeltaCommitActionExecutor.java | 4 +--
.../clean/TestCleanerInsertAndCleanByCommits.java | 2 +-
.../commit/TestCopyOnWriteActionExecutor.java | 2 +-
.../TestCopyOnWriteRollbackActionExecutor.java | 5 ---
.../hudi/testutils/HoodieClientTestUtils.java | 4 +--
.../testutils/HoodieSparkClientTestHarness.java | 2 +-
.../org/apache/hudi/BaseHoodieTableFileIndex.java | 2 +-
.../hudi/common/model/HoodiePartitionMetadata.java | 4 +--
.../hudi/common/table/HoodieTableConfig.java | 4 +--
.../table/log/BaseHoodieLogRecordReader.java | 6 ++--
.../timeline/versioning/v1/ActiveTimelineV1.java | 26 +++++++-------
.../timeline/versioning/v2/ActiveTimelineV2.java | 22 ++++++------
.../table/view/AbstractTableFileSystemView.java | 4 +--
.../table/view/HoodieTableFileSystemView.java | 2 +-
.../IncrementalTimelineSyncFileSystemView.java | 40 +++++++++++-----------
.../common/util/HoodieRecordSizeEstimator.java | 2 +-
.../org/apache/hudi/common/util/MarkerUtils.java | 2 +-
.../org/apache/hudi/common/util/RateLimiter.java | 5 ++-
.../common/util/collection/BitCaskDiskMap.java | 2 +-
.../hudi/metadata/HoodieBackedTableMetadata.java | 3 +-
.../SecondaryIndexRecordGenerationUtils.java | 2 +-
.../hudi/metrics/datadog/DatadogHttpClient.java | 4 +--
.../hudi/timeline/TimelineServiceClient.java | 2 +-
.../hudi/source/StreamReadMonitoringFunction.java | 4 +--
.../table/format/cow/CopyOnWriteInputFormat.java | 8 ++---
.../apache/hudi/table/ITTestSchemaEvolution.java | 7 ++--
.../vector/reader/BaseVectorizedColumnReader.java | 8 ++---
.../vector/reader/BaseVectorizedColumnReader.java | 8 ++---
.../vector/reader/BaseVectorizedColumnReader.java | 8 ++---
.../vector/reader/BaseVectorizedColumnReader.java | 8 ++---
.../vector/reader/BaseVectorizedColumnReader.java | 8 ++---
.../vector/reader/BaseVectorizedColumnReader.java | 8 ++---
.../org/apache/hudi/common/fs/TestFSUtils.java | 1 -
.../table/timeline/TestHoodieActiveTimeline.java | 2 +-
.../hudi/common/util/TestCompactionUtils.java | 1 -
.../common/util/collection/TestBitCaskDiskMap.java | 3 +-
.../hudi/hadoop/HoodieParquetInputFormat.java | 4 +--
.../hudi/hadoop/HoodieROTablePathFilter.java | 35 +++++--------------
.../hadoop/hive/HoodieCombineHiveInputFormat.java | 10 ++----
.../realtime/AbstractRealtimeRecordReader.java | 6 ++--
.../hudi/hadoop/utils/HoodieInputFormatUtils.java | 14 ++++----
.../utils/HoodieRealtimeInputFormatUtils.java | 9 +++--
.../utils/HoodieRealtimeRecordReaderUtils.java | 4 +--
.../dag/nodes/BaseValidateDatasetNode.java | 12 +++----
.../dag/nodes/DeleteInputDatasetNode.java | 2 +-
.../org/apache/hudi/common/util/FileIOUtils.java | 6 ++--
.../org/apache/hudi/common/util/RetryHelper.java | 2 +-
.../org/apache/hudi/connect/HoodieSinkTask.java | 2 +-
.../connect/kafka/KafkaConnectControlAgent.java | 4 +--
.../internal/DataSourceInternalWriterHelper.java | 2 +-
.../apache/hudi/cli/HDFSParquetImporterUtils.java | 10 +++---
.../src/test/java/HoodieJavaStreamingApp.java | 6 ++--
.../org/apache/hudi/TestAvroConversionHelper.scala | 2 --
.../hudi/TestAvroSchemaResolutionSupport.scala | 2 --
.../apache/hudi/functional/TestMORDataSource.scala | 5 +--
.../functional/TestParquetColumnProjection.scala | 2 --
.../hudi/functional/TestStructuredStreaming.scala | 1 -
.../hudi/sync/datahub/DataHubResponseLogger.java | 10 ++----
.../org/apache/hudi/hive/HoodieHiveSyncClient.java | 2 +-
.../org/apache/hudi/hive/util/HiveSchemaUtil.java | 12 +++----
.../org/apache/hudi/hive/TestHiveSyncTool.java | 3 --
.../apache/hudi/sync/common/HoodieSyncConfig.java | 12 ++++---
.../hudi/sync/common/util/ManifestFileWriter.java | 2 +-
.../timeline/service/handlers/MarkerHandler.java | 4 +--
.../marker/BatchedMarkerCreationRunnable.java | 2 +-
.../MarkerBasedEarlyConflictDetectionRunnable.java | 2 +-
.../marker/MarkerCreationDispatchingRunnable.java | 2 +-
.../handlers/marker/MarkerCreationFuture.java | 2 +-
.../service/handlers/marker/MarkerDirState.java | 10 +++---
.../TestRemoteHoodieTableFileSystemView.java | 2 +-
.../hudi/utilities/HoodieDataTableValidator.java | 6 ++--
.../org/apache/hudi/utilities/UtilHelpers.java | 10 +++---
.../kafka/HoodieWriteCommitKafkaCallback.java | 4 +--
.../hudi/utilities/sources/GcsEventsSource.java | 6 ++--
.../apache/hudi/utilities/sources/JdbcSource.java | 10 +++---
.../utilities/sources/debezium/DebeziumSource.java | 4 +--
.../sources/helpers/CloudObjectsSelector.java | 12 +++----
.../helpers/CloudObjectsSelectorCommon.java | 2 +-
.../helpers/IncrSourceCloudStorageHelper.java | 2 +-
.../sources/helpers/IncrSourceHelper.java | 2 +-
.../utilities/sources/helpers/QueryRunner.java | 2 +-
.../sources/helpers/S3EventsMetaSelector.java | 8 ++---
.../sources/helpers/gcs/PubsubMessagesFetcher.java | 2 +-
.../apache/hudi/utilities/streamer/StreamSync.java | 10 +++---
.../streamer/StreamerCheckpointUtils.java | 4 +--
.../deltastreamer/TestHoodieDeltaStreamer.java | 2 +-
.../TestHoodieDeltaStreamerDAGExecution.java | 1 -
.../TestHoodieMultiTableDeltaStreamer.java | 2 +-
137 files changed, 349 insertions(+), 423 deletions(-)
