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(-)