You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2023/04/01 12:17:57 UTC
[hudi] branch master updated (9c97340e001 -> 9a79a6d4631)
This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 9c97340e001 Bump protobuf-java from 3.21.5 to 3.21.7 (#6871)
add 9a79a6d4631 [HUDI-5649] Unify all the loggers to slf4j (#7955) (#7955)
No new revisions were added by this update.
Summary of changes:
.../hudi/aws/cloudwatch/CloudWatchReporter.java | 6 ++--
.../HoodieConfigAWSCredentialsProvider.java | 11 ++++----
.../hudi/aws/sync/AWSGlueCatalogSyncClient.java | 8 +++---
.../lock/DynamoDBBasedLockProvider.java | 25 ++++++++--------
.../hudi/cli/commands/ArchivedCommitsCommand.java | 6 ++--
.../hudi/cli/commands/CompactionCommand.java | 6 ++--
.../apache/hudi/cli/commands/MetadataCommand.java | 6 ++--
.../apache/hudi/cli/commands/RepairsCommand.java | 6 ++--
.../org/apache/hudi/cli/commands/SparkMain.java | 6 ++--
.../org/apache/hudi/cli/commands/TableCommand.java | 11 ++++----
.../apache/hudi/cli/commands/TimelineCommand.java | 13 +++++----
.../apache/hudi/cli/utils/InputStreamConsumer.java | 8 +++---
.../hudi/cli/utils/SparkTempViewProvider.java | 7 +++--
.../scala/org/apache/hudi/cli/DedupeSparkJob.scala | 7 ++---
.../hudi/cli/commands/TestRepairsCommand.java | 4 +--
.../cli/testutils/ShellEvaluationResultUtil.java | 6 ++--
.../org/apache/hudi/async/AsyncArchiveService.java | 6 ++--
.../org/apache/hudi/async/AsyncCleanerService.java | 6 ++--
.../apache/hudi/async/AsyncClusteringService.java | 6 ++--
.../org/apache/hudi/async/AsyncCompactService.java | 6 ++--
.../org/apache/hudi/async/HoodieAsyncService.java | 6 ++--
.../http/HoodieWriteCommitHttpCallbackClient.java | 11 ++++----
.../impl/HoodieWriteCommitHttpCallback.java | 6 ++--
.../org/apache/hudi/client/BaseHoodieClient.java | 6 ++--
.../hudi/client/BaseHoodieTableServiceClient.java | 6 ++--
.../apache/hudi/client/BaseHoodieWriteClient.java | 6 ++--
.../apache/hudi/client/CompactionAdminClient.java | 6 ++--
.../client/HoodieTableServiceManagerClient.java | 6 ++--
.../apache/hudi/client/HoodieTimelineArchiver.java | 6 ++--
.../apache/hudi/client/ReplaceArchivalHelper.java | 10 +++----
.../org/apache/hudi/client/RunsTableService.java | 6 ++--
.../java/org/apache/hudi/client/WriteStatus.java | 6 ++--
.../bootstrap/FullRecordBootstrapDataProvider.java | 10 +++----
.../selector/BootstrapRegexModeSelector.java | 16 ++++++-----
.../embedded/EmbeddedTimelineServerHelper.java | 6 ++--
.../client/embedded/EmbeddedTimelineService.java | 6 ++--
.../hudi/client/heartbeat/HeartbeatUtils.java | 6 ++--
.../client/heartbeat/HoodieHeartbeatClient.java | 6 ++--
...urrentFileWritesConflictResolutionStrategy.java | 7 +++--
.../client/transaction/TransactionManager.java | 6 ++--
.../lock/FileSystemBasedLockProvider.java | 17 +++++------
.../transaction/lock/InProcessLockProvider.java | 6 ++--
.../hudi/client/transaction/lock/LockManager.java | 6 ++--
.../lock/ZookeeperBasedLockProvider.java | 6 ++--
.../apache/hudi/client/utils/TransactionUtils.java | 10 +++----
.../org/apache/hudi/config/HoodieIndexConfig.java | 6 ++--
.../org/apache/hudi/config/HoodieWriteConfig.java | 6 ++--
.../org/apache/hudi/index/HoodieIndexUtils.java | 6 ++--
.../apache/hudi/index/bloom/HoodieBloomIndex.java | 7 +++--
.../hudi/index/bucket/HoodieBucketIndex.java | 6 ++--
.../hudi/index/bucket/HoodieSimpleBucketIndex.java | 7 +++--
.../hbase/DefaultHBaseQPSResourceAllocator.java | 6 ++--
.../org/apache/hudi/io/HoodieAppendHandle.java | 13 +++++----
.../org/apache/hudi/io/HoodieConcatHandle.java | 6 ++--
.../org/apache/hudi/io/HoodieCreateHandle.java | 11 ++++----
.../org/apache/hudi/io/HoodieKeyLookupHandle.java | 9 +++---
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 6 ++--
.../hudi/io/HoodieMergeHandleWithChangeLog.java | 13 +++++----
.../hudi/io/HoodieUnboundedCreateHandle.java | 6 ++--
.../java/org/apache/hudi/io/HoodieWriteHandle.java | 6 ++--
.../metadata/HoodieBackedTableMetadataWriter.java | 6 ++--
.../hudi/metrics/ConsoleMetricsReporter.java | 6 ++--
.../org/apache/hudi/metrics/HoodieMetrics.java | 6 ++--
.../apache/hudi/metrics/JmxMetricsReporter.java | 5 ++--
.../main/java/org/apache/hudi/metrics/Metrics.java | 6 ++--
.../hudi/metrics/MetricsGraphiteReporter.java | 6 ++--
.../hudi/metrics/MetricsReporterFactory.java | 6 ++--
.../cloudwatch/CloudWatchMetricsReporter.java | 6 ++--
.../hudi/metrics/datadog/DatadogHttpClient.java | 6 ++--
.../hudi/metrics/datadog/DatadogReporter.java | 6 ++--
.../metrics/prometheus/PrometheusReporter.java | 6 ++--
.../metrics/prometheus/PushGatewayReporter.java | 13 ++++-----
.../java/org/apache/hudi/table/HoodieTable.java | 6 ++--
.../table/action/clean/CleanActionExecutor.java | 6 ++--
.../action/clean/CleanPlanActionExecutor.java | 6 ++--
.../hudi/table/action/clean/CleanPlanner.java | 6 ++--
.../cluster/ClusteringPlanActionExecutor.java | 6 ++--
.../strategy/ClusteringExecutionStrategy.java | 6 ++--
.../cluster/strategy/ClusteringPlanStrategy.java | 6 ++--
.../PartitionAwareClusteringPlanStrategy.java | 6 ++--
.../action/commit/BaseCommitActionExecutor.java | 6 ++--
.../table/action/commit/HoodieMergeHelper.java | 6 ++--
.../hudi/table/action/compact/HoodieCompactor.java | 6 ++--
.../compact/LogCompactionExecutionHelper.java | 7 +++--
.../compact/ScheduleCompactionActionExecutor.java | 6 ++--
.../BaseHoodieCompactionPlanGenerator.java | 7 +++--
.../generators/HoodieCompactionPlanGenerator.java | 7 +++--
.../HoodieLogCompactionPlanGenerator.java | 7 +++--
.../table/action/index/RunIndexActionExecutor.java | 6 ++--
.../action/index/ScheduleIndexActionExecutor.java | 6 ++--
.../action/restore/BaseRestoreActionExecutor.java | 6 ++--
.../rollback/BaseRollbackActionExecutor.java | 6 ++--
.../table/action/rollback/BaseRollbackHelper.java | 6 ++--
.../rollback/BaseRollbackPlanActionExecutor.java | 6 ++--
.../CopyOnWriteRollbackActionExecutor.java | 6 ++--
.../rollback/ListingBasedRollbackStrategy.java | 6 ++--
.../rollback/MarkerBasedRollbackStrategy.java | 6 ++--
.../MergeOnReadRollbackActionExecutor.java | 6 ++--
.../action/rollback/RestorePlanActionExecutor.java | 6 ++--
.../hudi/table/action/rollback/RollbackUtils.java | 9 +++---
.../action/savepoint/SavepointActionExecutor.java | 6 ++--
.../table/action/savepoint/SavepointHelpers.java | 7 +++--
.../hudi/table/marker/DirectWriteMarkers.java | 6 ++--
.../table/marker/MarkerBasedRollbackUtils.java | 6 ++--
.../SimpleDirectMarkerBasedDetectionStrategy.java | 6 ++--
...nsactionDirectMarkerBasedDetectionStrategy.java | 6 ++--
.../marker/TimelineServerBasedWriteMarkers.java | 6 ++--
.../org/apache/hudi/table/marker/WriteMarkers.java | 6 ++--
.../hudi/table/marker/WriteMarkersFactory.java | 6 ++--
.../table/upgrade/FourToFiveUpgradeHandler.java | 6 ++--
.../hudi/table/upgrade/UpgradeDowngrade.java | 6 ++--
.../org/apache/hudi/HoodieTestCommitGenerator.java | 6 ++--
.../transaction/TestInProcessLockProvider.java | 9 +++---
.../hudi/client/transaction/TestLockManager.java | 6 ++--
.../TestZookeeperBasedLockProvider.java | 6 ++--
.../hudi/metrics/datadog/TestDatadogReporter.java | 2 +-
.../hudi/testutils/HoodieWriteableTestTable.java | 21 +++++++-------
.../FlinkSizeBasedClusteringPlanStrategy.java | 6 ++--
.../hudi/index/state/FlinkInMemoryStateIndex.java | 6 ++--
.../java/org/apache/hudi/io/FlinkCreateHandle.java | 6 ++--
.../apache/hudi/io/FlinkMergeAndReplaceHandle.java | 6 ++--
.../FlinkMergeAndReplaceHandleWithChangeLog.java | 8 +++---
.../java/org/apache/hudi/io/FlinkMergeHandle.java | 6 ++--
.../hudi/io/FlinkMergeHandleWithChangeLog.java | 8 +++---
.../io/storage/row/HoodieRowDataCreateHandle.java | 6 ++--
.../FlinkHoodieBackedTableMetadataWriter.java | 6 ++--
.../commit/BaseFlinkCommitActionExecutor.java | 6 ++--
.../testutils/HoodieFlinkClientTestHarness.java | 6 ++--
.../testutils/HoodieFlinkWriteableTestTable.java | 6 ++--
.../JavaSizeBasedClusteringPlanStrategy.java | 7 +++--
.../run/strategy/JavaExecutionStrategy.java | 11 ++++----
.../strategy/JavaSortAndSizeExecutionStrategy.java | 8 +++---
.../commit/BaseJavaCommitActionExecutor.java | 6 ++--
.../table/action/commit/JavaUpsertPartitioner.java | 6 ++--
...JavaUpsertPreppedDeltaCommitActionExecutor.java | 6 ++--
.../commit/TestJavaCopyOnWriteActionExecutor.java | 8 +++---
.../testutils/HoodieJavaClientTestHarness.java | 6 ++--
.../hudi/client/HoodieSparkClusteringClient.java | 8 +++---
.../apache/hudi/client/HoodieSparkCompactor.java | 6 ++--
.../apache/hudi/client/SparkRDDWriteClient.java | 6 ++--
...parkConsistentBucketClusteringPlanStrategy.java | 6 ++--
.../SparkSizeBasedClusteringPlanStrategy.java | 6 ++--
.../MultipleSparkJobExecutionStrategy.java | 6 ++--
.../strategy/SingleSparkJobExecutionStrategy.java | 6 ++--
...onsistentBucketClusteringExecutionStrategy.java | 6 ++--
.../SparkSingleFileSortExecutionStrategy.java | 8 +++---
.../SparkSortAndSizeExecutionStrategy.java | 8 +++---
...arkConsistentBucketDuplicateUpdateStrategy.java | 6 ++--
.../update/strategy/SparkRejectUpdateStrategy.java | 6 ++--
.../client/common/HoodieSparkEngineContext.java | 6 ++--
.../hudi/client/utils/SparkValidatorUtils.java | 6 ++--
.../client/validator/SparkPreCommitValidator.java | 6 ++--
.../SqlQueryEqualityPreCommitValidator.java | 6 ++--
.../SqlQueryInequalityPreCommitValidator.java | 6 ++--
.../validator/SqlQueryPreCommitValidator.java | 6 ++--
.../SqlQuerySingleResultPreCommitValidator.java | 6 ++--
.../bulkinsert/RDDConsistentBucketPartitioner.java | 6 ++--
.../bloom/BucketizedBloomCheckPartitioner.java | 6 ++--
.../index/bloom/HoodieFileProbingFunction.java | 12 ++++----
.../HoodieMetadataBloomFilterProbingFunction.java | 10 ++++---
.../index/bloom/SparkHoodieBloomIndexHelper.java | 12 ++++----
.../bucket/HoodieSparkConsistentBucketIndex.java | 6 ++--
.../hudi/index/hbase/SparkHoodieHBaseIndex.java | 15 +++++-----
.../hudi/io/storage/row/HoodieRowCreateHandle.java | 6 ++--
.../apache/hudi/keygen/BuiltinKeyGenerator.java | 13 +++++----
.../SparkHoodieBackedTableMetadataWriter.java | 6 ++--
.../apache/hudi/sort/SpaceCurveSortingHelper.java | 13 +++++----
.../hudi/table/HoodieSparkCopyOnWriteTable.java | 7 +++--
.../bootstrap/BaseBootstrapMetadataHandler.java | 11 ++++----
.../bootstrap/OrcBootstrapMetadataHandler.java | 6 ++--
.../SparkBootstrapCommitActionExecutor.java | 6 ++--
.../commit/BaseSparkCommitActionExecutor.java | 6 ++--
.../commit/BulkInsertDataInternalWriterHelper.java | 7 +++--
.../commit/SparkInsertOverwritePartitioner.java | 6 ++--
.../table/action/commit/UpsertPartitioner.java | 6 ++--
.../BaseSparkDeltaCommitActionExecutor.java | 6 ++--
.../hudi/client/TestCompactionAdminClient.java | 6 ++--
.../java/org/apache/hudi/client/TestMultiFS.java | 6 ++--
.../functional/TestHoodieBackedMetadata.java | 12 ++++----
.../functional/TestHoodieBackedTableMetadata.java | 6 ++--
.../TestHoodieClientOnCopyOnWriteStorage.java | 6 ++--
.../client/functional/TestHoodieMetadataBase.java | 6 ++--
.../functional/TestHoodieMetadataBootstrap.java | 6 ++--
.../TestRemoteFileSystemViewWithMetadataTable.java | 8 +++---
.../index/bucket/TestHoodieSimpleBucketIndex.java | 6 ++--
.../apache/hudi/io/TestHoodieTimelineArchiver.java | 6 ++--
.../clean/TestCleanerInsertAndCleanByCommits.java | 6 ++--
.../commit/TestCopyOnWriteActionExecutor.java | 8 +++---
.../table/action/commit/TestUpsertPartitioner.java | 8 +++---
.../hudi/testutils/HoodieClientTestBase.java | 6 ++--
.../hudi/testutils/HoodieClientTestHarness.java | 12 ++++----
.../hudi/testutils/HoodieClientTestUtils.java | 6 ++--
.../hudi/testutils/HoodieMergeOnReadTestUtils.java | 8 +++---
.../testutils/HoodieSparkWriteableTestTable.java | 6 ++--
.../org/apache/hudi/BaseHoodieTableFileIndex.java | 6 ++--
.../bootstrap/index/HFileBootstrapIndex.java | 6 ++--
.../common/config/DFSPropertiesConfiguration.java | 6 ++--
.../apache/hudi/common/config/HoodieConfig.java | 6 ++--
.../DirectMarkerBasedDetectionStrategy.java | 6 ++--
.../java/org/apache/hudi/common/fs/FSUtils.java | 6 ++--
.../hudi/common/fs/FailSafeConsistencyGuard.java | 6 ++--
.../hudi/common/fs/OptimisticConsistencyGuard.java | 6 ++--
.../common/heartbeat/HoodieHeartbeatUtils.java | 6 ++--
.../hudi/common/model/HoodieCommitMetadata.java | 6 ++--
.../model/HoodieConsistentHashingMetadata.java | 6 ++--
.../hudi/common/model/HoodiePartitionMetadata.java | 6 ++--
.../common/model/HoodieReplaceCommitMetadata.java | 6 ++--
.../common/model/HoodieRollingStatMetadata.java | 6 ++--
.../debezium/AbstractDebeziumAvroPayload.java | 6 ++--
.../model/debezium/MySqlDebeziumAvroPayload.java | 6 ++--
.../debezium/PostgresDebeziumAvroPayload.java | 6 ++--
.../hudi/common/table/HoodieTableConfig.java | 6 ++--
.../hudi/common/table/HoodieTableMetaClient.java | 6 ++--
.../hudi/common/table/TableSchemaResolver.java | 6 ++--
.../table/log/AbstractHoodieLogRecordReader.java | 6 ++--
.../hudi/common/table/log/HoodieLogFileReader.java | 6 ++--
.../hudi/common/table/log/HoodieLogFormat.java | 6 ++--
.../common/table/log/HoodieLogFormatReader.java | 6 ++--
.../common/table/log/HoodieLogFormatWriter.java | 6 ++--
.../table/log/HoodieMergedLogRecordScanner.java | 9 +++---
.../table/timeline/HoodieActiveTimeline.java | 6 ++--
.../table/timeline/HoodieArchivedTimeline.java | 6 ++--
.../common/table/timeline/TimelineDiffHelper.java | 6 ++--
.../hudi/common/table/timeline/TimelineUtils.java | 6 ++--
.../table/view/AbstractTableFileSystemView.java | 6 ++--
.../common/table/view/FileSystemViewManager.java | 6 ++--
.../table/view/HoodieTableFileSystemView.java | 6 ++--
.../IncrementalTimelineSyncFileSystemView.java | 6 ++--
.../table/view/PriorityBasedFileSystemView.java | 6 ++--
.../view/RemoteHoodieTableFileSystemView.java | 6 ++--
.../table/view/RocksDbBasedFileSystemView.java | 6 ++--
.../view/SpillableMapBasedFileSystemView.java | 6 ++--
.../hudi/common/util/BufferedRandomAccessFile.java | 5 ++--
.../org/apache/hudi/common/util/CleanerUtils.java | 6 ++--
.../apache/hudi/common/util/ClusteringUtils.java | 6 ++--
.../org/apache/hudi/common/util/CommitUtils.java | 6 ++--
.../org/apache/hudi/common/util/FileIOUtils.java | 6 ++--
.../common/util/HoodieRecordSizeEstimator.java | 6 ++--
.../apache/hudi/common/util/HoodieRecordUtils.java | 18 ++++++------
.../hudi/common/util/InternalSchemaCache.java | 8 +++---
.../org/apache/hudi/common/util/MarkerUtils.java | 6 ++--
.../org/apache/hudi/common/util/ParquetUtils.java | 6 ++--
.../org/apache/hudi/common/util/RateLimiter.java | 6 ++--
.../apache/hudi/common/util/ReflectionUtils.java | 6 ++--
.../org/apache/hudi/common/util/RetryHelper.java | 6 ++--
.../apache/hudi/common/util/TablePathUtils.java | 6 ++--
.../common/util/collection/BitCaskDiskMap.java | 6 ++--
.../hudi/common/util/collection/DiskMap.java | 6 ++--
.../util/collection/ExternalSpillableMap.java | 7 +++--
.../hudi/common/util/collection/RocksDBDAO.java | 6 ++--
.../common/util/collection/RocksDbDiskMap.java | 6 ++--
.../util/queue/BaseHoodieQueueBasedExecutor.java | 7 +++--
.../common/util/queue/BoundedInMemoryExecutor.java | 7 +++--
.../common/util/queue/BoundedInMemoryQueue.java | 6 ++--
.../common/util/queue/DisruptorMessageQueue.java | 6 ++--
.../util/queue/FunctionBasedQueueProducer.java | 6 ++--
.../util/queue/IteratorBasedQueueProducer.java | 7 +++--
.../hudi/common/util/queue/SimpleExecutor.java | 7 +++--
.../io/FileBasedInternalSchemaStorageManager.java | 6 ++--
.../hudi/io/storage/HoodieAvroHFileReader.java | 6 ++--
.../apache/hudi/metadata/BaseTableMetadata.java | 8 +++---
.../hudi/metadata/HoodieBackedTableMetadata.java | 6 ++--
.../hudi/metadata/HoodieMetadataMetrics.java | 6 ++--
.../hudi/metadata/HoodieTableMetadataUtil.java | 6 ++--
.../table/view/TestHoodieTableFileSystemView.java | 6 ++--
.../table/view/TestIncrementalFSViewSync.java | 6 ++--
.../hudi/common/testutils/FileCreateUtils.java | 6 ++--
.../common/testutils/HoodieTestDataGenerator.java | 6 ++--
.../hudi/common/testutils/HoodieTestTable.java | 6 ++--
.../testutils/minicluster/HdfsTestService.java | 6 ++--
.../minicluster/ZookeeperTestService.java | 6 ++--
.../HoodieBackedTestDelayedTableMetadata.java | 6 ++--
.../java/HoodieJavaWriteClientExample.java | 6 ++--
.../examples/spark/HoodieWriteClientExample.java | 9 +++---
.../hudi/sink/bulk/BulkInsertWriterHelper.java | 6 ++--
.../hudi/sink/partitioner/BucketAssigner.java | 6 ++--
.../java/org/apache/hudi/util/HoodiePipeline.java | 10 +++----
.../apache/hudi/gcp/bigquery/BigQuerySyncTool.java | 6 ++--
.../gcp/bigquery/HoodieBigQuerySyncClient.java | 6 ++--
.../BootstrapColumnStichingRecordReader.java | 9 +++---
.../hadoop/HoodieCopyOnWriteTableInputFormat.java | 6 ++--
.../hudi/hadoop/HoodieParquetInputFormat.java | 13 +++++----
.../hudi/hadoop/HoodieROTablePathFilter.java | 6 ++--
.../org/apache/hudi/hadoop/InputPathHandler.java | 8 +++---
.../hudi/hadoop/RecordReaderValueIterator.java | 6 ++--
.../apache/hudi/hadoop/SchemaEvolutionContext.java | 10 +++----
.../hadoop/hive/HoodieCombineHiveInputFormat.java | 21 +++++++-------
.../realtime/AbstractRealtimeRecordReader.java | 6 ++--
.../HoodieCombineRealtimeRecordReader.java | 6 ++--
.../realtime/HoodieHFileRealtimeInputFormat.java | 21 +++++++-------
.../realtime/HoodieParquetRealtimeInputFormat.java | 23 +++++++--------
.../realtime/HoodieRealtimeRecordReader.java | 6 ++--
.../realtime/RealtimeCompactedRecordReader.java | 21 +++++++-------
.../hudi/hadoop/utils/HiveAvroSerializer.java | 11 ++++----
.../apache/hudi/hadoop/utils/HoodieHiveUtils.java | 11 ++++----
.../hudi/hadoop/utils/HoodieInputFormatUtils.java | 33 +++++++++++-----------
.../utils/HoodieRealtimeInputFormatUtils.java | 17 +++++------
.../utils/HoodieRealtimeRecordReaderUtils.java | 6 ++--
.../testsuite/HoodieMultiWriterTestSuiteJob.java | 6 ++--
.../SparkDataSourceContinuousIngestTool.java | 6 ++--
.../hudi/integ/testsuite/dag/WriterContext.java | 8 +++---
.../dag/scheduler/SaferSchemaDagScheduler.java | 7 +++--
.../schema/TestSuiteFileBasedSchemaProvider.java | 6 ++--
.../SparkDataSourceContinuousIngest.scala | 4 +--
.../testsuite/dag/nodes/SparkDeleteNode.scala | 4 +--
.../dag/nodes/SparkDeletePartitionNode.scala | 10 ++-----
.../testsuite/dag/nodes/SparkInsertNode.scala | 4 +--
.../testsuite/dag/nodes/SparkUpsertNode.scala | 4 +--
.../java/org/apache/hudi/integ/ITTestBase.java | 6 ++--
.../testsuite/job/TestHoodieTestSuiteJob.java | 4 +--
.../apache/hudi/connect/HoodieSinkConnector.java | 6 ++--
.../org/apache/hudi/connect/HoodieSinkTask.java | 6 ++--
.../connect/KafkaConnectFileIdPrefixProvider.java | 6 ++--
.../connect/kafka/KafkaConnectControlAgent.java | 6 ++--
.../hudi/connect/kafka/KafkaControlProducer.java | 6 ++--
.../transaction/ConnectTransactionCoordinator.java | 6 ++--
.../transaction/ConnectTransactionParticipant.java | 6 ++--
.../hudi/connect/utils/KafkaConnectUtils.java | 6 ++--
.../connect/writers/AbstractConnectWriter.java | 6 ++--
.../connect/writers/BufferedConnectWriter.java | 6 ++--
.../writers/KafkaConnectTransactionServices.java | 6 ++--
.../writers/KafkaConnectWriterProvider.java | 14 ++++-----
.../common/table/HoodieTableMetaserverClient.java | 6 ++--
.../client/HoodieMetaserverClientImp.java | 7 +++--
.../apache/hudi/metaserver/HoodieMetaserver.java | 9 +++---
.../service/HoodieMetaserverProxyHandler.java | 7 +++--
.../hudi/metaserver/service/TimelineService.java | 5 ++--
.../store/jdbc/SqlSessionFactoryUtils.java | 6 ++--
.../hudi/metaserver/util/TServerSocketWrapper.java | 6 ++--
.../main/java/org/apache/hudi/DataSourceUtils.java | 17 +++++------
.../internal/DataSourceInternalWriterHelper.java | 7 +++--
.../scala/org/apache/hudi/DataSourceOptions.scala | 4 +--
.../main/scala/org/apache/hudi/DefaultSource.scala | 8 +++---
.../org/apache/hudi/HoodieSparkSqlWriter.scala | 6 ++--
.../org/apache/hudi/HoodieStreamingSink.scala | 4 +--
.../org/apache/hudi/IncrementalRelation.scala | 5 ++--
.../org/apache/hudi/cli/ArchiveExecutorUtils.java | 8 +++---
.../apache/hudi/cli/BootstrapExecutorUtils.java | 6 ++--
.../apache/hudi/cli/HDFSParquetImporterUtils.java | 26 +++++++++--------
.../org/apache/spark/sql/hudi/DedupeSparkJob.scala | 4 +--
.../hudi-spark/src/test/java/HoodieJavaApp.java | 6 ++--
.../src/test/java/HoodieJavaGenerateApp.java | 6 ++--
.../src/test/java/HoodieJavaStreamingApp.java | 6 ++--
.../hudi/functional/TestHoodieActiveTimeline.scala | 7 ++---
.../TestIncrementalReadWithFullTableScan.scala | 10 +++----
.../apache/hudi/functional/TestMORDataSource.scala | 4 +--
.../hudi/functional/TestMORDataSourceStorage.scala | 4 +--
.../hudi/functional/TestStreamingSource.scala | 3 +-
.../hudi/functional/TestStructuredStreaming.scala | 6 ++--
.../spark/sql/hudi/HoodieSparkSqlTestBase.scala | 3 +-
.../hudi/sync/datahub/DatahubResponseLogger.java | 6 ++--
.../java/org/apache/hudi/hive/HiveSyncTool.java | 6 ++--
.../org/apache/hudi/hive/HoodieHiveSyncClient.java | 6 ++--
.../org/apache/hudi/hive/ddl/HMSDDLExecutor.java | 6 ++--
.../apache/hudi/hive/ddl/HiveQueryDDLExecutor.java | 6 ++--
.../org/apache/hudi/hive/ddl/JDBCExecutor.java | 6 ++--
.../hudi/hive/ddl/QueryBasedDDLExecutor.java | 6 ++--
.../hudi/hive/replication/GlobalHiveSyncTool.java | 6 ++--
.../replication/HiveSyncGlobalCommitParams.java | 6 ++--
.../hive/replication/HiveSyncGlobalCommitTool.java | 6 ++--
.../lock/HiveMetastoreBasedLockProvider.java | 19 +++++++------
.../apache/hudi/hive/util/HivePartitionUtil.java | 6 ++--
.../org/apache/hudi/hive/util/HiveSchemaUtil.java | 6 ++--
.../hudi/hive/testutils/HiveTestService.java | 6 ++--
.../apache/hudi/sync/common/HoodieSyncClient.java | 6 ++--
.../apache/hudi/sync/common/HoodieSyncConfig.java | 6 ++--
.../hudi/sync/common/util/ManifestFileWriter.java | 6 ++--
.../hudi/sync/common/util/SyncUtilHelpers.java | 6 ++--
.../hudi/timeline/service/RequestHandler.java | 6 ++--
.../hudi/timeline/service/TimelineService.java | 6 ++--
.../timeline/service/handlers/MarkerHandler.java | 6 ++--
.../AsyncTimelineServerBasedDetectionStrategy.java | 6 ++--
.../marker/BatchedMarkerCreationRunnable.java | 6 ++--
.../MarkerBasedEarlyConflictDetectionRunnable.java | 6 ++--
.../marker/MarkerCreationDispatchingRunnable.java | 6 ++--
.../handlers/marker/MarkerCreationFuture.java | 6 ++--
.../service/handlers/marker/MarkerDirState.java | 6 ++--
.../TestRemoteHoodieTableFileSystemView.java | 6 ++--
...tMarkerBasedEarlyConflictDetectionRunnable.java | 6 ++--
.../apache/hudi/utilities/HDFSParquetImporter.java | 8 +++---
.../hudi/utilities/HiveIncrementalPuller.java | 6 ++--
.../org/apache/hudi/utilities/HoodieCleaner.java | 13 +++++----
.../apache/hudi/utilities/HoodieClusteringJob.java | 6 ++--
.../org/apache/hudi/utilities/HoodieCompactor.java | 17 ++++++-----
.../hudi/utilities/HoodieDataTableValidator.java | 8 +++---
.../hudi/utilities/HoodieDropPartitionsTool.java | 6 ++--
.../org/apache/hudi/utilities/HoodieIndexer.java | 6 ++--
.../utilities/HoodieMetadataTableValidator.java | 10 +++----
.../apache/hudi/utilities/HoodieRepairTool.java | 6 ++--
.../hudi/utilities/HoodieSnapshotCopier.java | 6 ++--
.../hudi/utilities/HoodieSnapshotExporter.java | 6 ++--
.../org/apache/hudi/utilities/UtilHelpers.java | 6 ++--
.../kafka/HoodieWriteCommitKafkaCallback.java | 6 ++--
.../pulsar/HoodieWriteCommitPulsarCallback.java | 6 ++--
.../utilities/deltastreamer/BootstrapExecutor.java | 6 ++--
.../hudi/utilities/deltastreamer/DeltaSync.java | 6 ++--
.../deltastreamer/HoodieDeltaStreamer.java | 6 ++--
.../HoodieMultiTableDeltaStreamer.java | 6 ++--
.../NoNewDataTerminationStrategy.java | 6 ++--
.../deltastreamer/SchedulerConfGenerator.java | 6 ++--
.../ingestion/HoodieIngestionService.java | 6 ++--
.../hudi/utilities/perf/TimelineServerPerf.java | 6 ++--
.../utilities/schema/KafkaOffsetPostProcessor.java | 6 ++--
.../DeleteSupportSchemaPostProcessor.java | 8 +++---
.../DropColumnSchemaPostProcessor.java | 6 ++--
.../hudi/utilities/sources/AvroKafkaSource.java | 6 ++--
.../sources/GcsEventsHoodieIncrSource.java | 6 ++--
.../hudi/utilities/sources/GcsEventsSource.java | 6 ++--
.../hudi/utilities/sources/HiveIncrPullSource.java | 6 ++--
.../hudi/utilities/sources/HoodieIncrSource.java | 6 ++--
.../apache/hudi/utilities/sources/JdbcSource.java | 6 ++--
.../apache/hudi/utilities/sources/KafkaSource.java | 6 ++--
.../hudi/utilities/sources/PulsarSource.java | 7 +++--
.../sources/S3EventsHoodieIncrSource.java | 6 ++--
.../apache/hudi/utilities/sources/SqlSource.java | 7 +++--
.../utilities/sources/debezium/DebeziumSource.java | 6 ++--
.../sources/helpers/CloudObjectsSelector.java | 6 ++--
.../helpers/CloudObjectsSelectorCommon.java | 13 +++++----
.../utilities/sources/helpers/DFSPathSelector.java | 8 +++---
.../sources/helpers/DatePartitionPathSelector.java | 6 ++--
.../helpers/IncrSourceCloudStorageHelper.java | 11 +++++---
.../utilities/sources/helpers/KafkaOffsetGen.java | 6 ++--
.../sources/helpers/gcs/FileDataFetcher.java | 8 ++++--
.../sources/helpers/gcs/FilePathsFetcher.java | 8 ++++--
.../sources/helpers/gcs/MetadataMessage.java | 6 ++--
.../sources/helpers/gcs/PubsubMessagesFetcher.java | 14 +++++----
.../utilities/sources/helpers/gcs/QueryInfo.java | 6 ++--
.../utilities/transform/FlatteningTransformer.java | 6 ++--
.../transform/SqlFileBasedTransformer.java | 6 ++--
.../transform/SqlQueryBasedTransformer.java | 6 ++--
.../hudi/utilities/TestHoodieRepairTool.java | 6 ++--
.../deltastreamer/TestHoodieDeltaStreamer.java | 6 ++--
.../TestHoodieDeltaStreamerWithMultiWriter.java | 6 ++--
.../TestHoodieMultiTableDeltaStreamer.java | 6 ++--
.../functional/TestHiveSchemaProvider.java | 9 +++---
.../functional/TestHoodieSnapshotExporter.java | 6 ++--
.../functional/TestJdbcbasedSchemaProvider.java | 6 ++--
.../hudi/utilities/sources/TestDataSource.java | 6 ++--
.../sources/TestGcsEventsHoodieIncrSource.java | 13 +++++----
.../hudi/utilities/testutils/JdbcTestUtils.java | 6 ++--
.../utilities/testutils/UtilitiesTestBase.java | 8 ++----
.../testutils/sources/AbstractBaseTestSource.java | 6 ++--
.../sources/DistributedTestDataSource.java | 6 ++--
packaging/hudi-cli-bundle/pom.xml | 11 ++++++++
style/checkstyle.xml | 2 +-
445 files changed, 1619 insertions(+), 1539 deletions(-)