You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by co...@apache.org on 2023/04/20 10:03:33 UTC
[hudi] branch release-0.12.1 updated (45bef56db55 -> a5978cd2308)
This is an automated email from the ASF dual-hosted git repository.
codope pushed a change to branch release-0.12.1
in repository https://gitbox.apache.org/repos/asf/hudi.git
discard 45bef56db55 [HUDI-5495] add some property to table config
discard 7588b918de2 add DropPartitionsProcedure
discard 0f056e52e58 [HUDI-5286] UnsupportedOperationException throws when enabling filesystem retry (#7313)
discard 108c6afd308 [HUDI-4968] Update misleading read.streaming.skip_compaction/skip_clustering config (#6856)
discard c265ddcc4b5 [HUDI-5506] StreamWriteOperatorCoordinator may not recommit with partial uncommitted write metadata event (#7611)
discard e44285447a1 improve getCommitInstantsToArchive data duplication
discard ee779fe86fe [HUDI-5341] CleanPlanner retains earliest commits must not be later than earliest pending commit (#7568)
discard 700717c7344 [HUDI-5235] Clustering target size should larger than small file limit (#7232)
discard 94ee9a133ad [HUDI-5543] Description of clustering.plan.partition.filter.mode supports DAY_ROLLING strategy (#7656)
discard 09df7305557 [HUDI-5515] Fix concurrency conflict in ClusteringOperator with latency marker (#7625)
discard 59094436c9d [HUDI-5343] HoodieFlinkStreamer supports async clustering for append mode (#7403)
discard cca17a599d6 [MINOR] improve RunClusteringProcedure with partition selected
discard 5e2db20bb20 fix Zhiyan metrics reporter
discard 2c8586f5a3b fix enable metrics on
discard b0a0912cfaf [HUDI-5326] Fix clustering group building in SparkSizeBasedClusteringPlanStrategy (#7372)
discard 3c4a403a0a3 [HUDI-5318] Fix partition pruning for clustering scheduling (#7366)
discard 0344765bdf3 [HUDI-5671] BucketIndexPartitioner partition algorithm skew (#7815)
discard 9a9fd985f2f improve BackupInvalidParquetProcedure
discard ebf99a7e84f [HUDI-5278] Support more conf to cluster procedure (#7304)
discard d8043d48ea0 fix metatable hbase-site
discard 2a3b0b5af8a add DeleteFsFileProcedure
discard e208d0168fb add DeleteRollbackInstantProcedure
discard 4bd7cf428bd [HUDI-5548] spark sql update hudi's table properties
discard 8b357947e15 fix readDataFromPath check fs exists
discard 7da379b6597 [HUDI-5495] add some property to table config
discard dd032bb1fe2 [HUDI-5302] Fix: compute hash key from recordKey failed when recordKeyValue contains ',' (#7342)
discard 9e124834aae [HUDI-4959] Fixing Avro's `Utf8` serialization in Kryo (#7024)
discard b77aa2e1b83 [HUDI-5511] Do not clean the CkpMetadata dir when restart the job (#7620)
discard 27ada3a78a2 [HUDI-5502] Support insert overwrite for flink mor table with bucket index (#7610)
discard dac93e22f0b [HUDI-5477] Optimize timeline loading in Hudi sync client (#7561)
discard 83a0cab485d [HUDI-5492] spark call command 'show_compaction' doesn't return the completed compaction (#7593)
discard 5d22790a6c4 improve checkstyle
discard 464bf28895c fix metatable hbase hfile hadoop3
discard bf171d5eb85 fix metatable writing multiple records with same key
discard 1ae6814e7f9 fix metatable compaction requested already exists
discard 257b09003b4 [MINOR] Improve spillableMapBasePath when disk directory is full
discard 283b25a8a6b [MINOR] add some property to table config
discard 78fe5c73a4a [HUDI-3572] support DAY_ROLLING strategy in ClusteringPlanPartitionFilterMode (#4966)
discard 4f005ea5d45 improve DropHoodieTableCommand
discard d0b3b36e96d check parquet file does not exist
discard 79abc24265d improve checkstyle
discard 4fe2aec44ac fix read log not exist
discard 5488c951e41 [HUDI-5314] add call help procedure (#7361)
discard e0faa0bbe10 [HUDI-5350] Fix oom cause compaction event lost problem (#7408)
discard 0d71705ec22 [MINOR] add integrity check of parquet file for HoodieRowDataParquetWriter.
discard adc8aa6ebd0 remove ZhiyanReporter's report print
discard bddf061a794 [HUDI-5223] Partial failover for flink (#7208)
discard 0cf7d3dac8b fix database default error
discard f2256ec94cc exclude hudi-kafka-connect & add some api to support FLIP-27 source
discard b1f204fa551 Merge branch 'release-0.12.1' of https://git.woa.com/data-lake-technology/hudi into release-0.12.1
discard 619b7504ca1 Reduce the scope and duration of holding checkpoint lock in stream read
discard c070e0963a0 [HUDI-5095] Flink: Stores a special watermark(flag) to identify the current progress of writing data
discard ab5deef087a Merge branch 'optimize_schema_settings' into 'release-0.12.1' (merge request !108)
discard f7fe437faf8 Fix tauth issue (merge request !102)
discard 005e9134038 [HUDI-5095] Flink: Stores a special watermark(flag) to identify the current progress of writing data
discard f02fef936b7 fix none index partition format
discard 00c3443cb41 optimize schema settings
discard 9fbf3b920d2 [HUDI-5095] Flink: Stores a special watermark(flag) to identify the current progress of writing data
discard e95a9f56ae2 [HUDI-4526] Improve spillableMapBasePath when disk directory is full (#6284)
discard 7d6654c1d0a [HUDI-5178] Add Call show_table_properties for spark sql (#7161)
discard 738e2cce8f4 [HUDI-4898] presto/hive respect payload during merge parquet file and logfile when reading mor table (#6741)
discard 3c364bdf721 [MINOR] add integrity check of merged parquet file for HoodieMergeHandle.
discard 5f6d6ae42d4 remove hudi-kafka-connect module
discard ecd39e3ad76 add log to print scanInternal's logFilePath
discard 90c09053da7 [HUDI-5105] Add Call show_commit_extra_metadata for spark sql (#7091)
discard 97ce2b7f7ba temp_view_support (#6990)
discard 8ba01dc70a7 [HUDI-2624] Implement Non Index type for HUDI
discard ee07cc6a3ba Remove proxy
discard 8d692f38c14 [HUDI-5041] Fix lock metric register confict error (#6968)
discard 4e66857849d fix RowDataProjection with project and projectAsValues's NPE
discard 895f260983f opt procedure backup_invalid_parquet
discard e45564102b0 fix file not exists for getFileSize
discard 9c94e388fec adapt tspark changes: backport 3.3 VectorizedParquetReader related code to 3.1
discard f80900d91cd [MINOR] Adapt to tianqiong spark
discard 6dbe53e6232 fix zhiyan reporter for metadata
discard 1d029e668bd add 'backup_invalid_parquet' procedure
discard c1ceb628e57 [MINOR] fix Invalid value for YearOfEra
discard 553bb9eab47 [HUDI-4475] fix create table with not exists hoodie properties file
discard ab5b4fa780c fix the bug, log file will not roll over to a new file
discard d785b41f010 fix cherry pick err
discard 23412b2bee1 [MINOR] Add Zhiyan metrics reporter
discard ac0d1d81a48 [MINOR] Adapt to tianqiong spark
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/release-0.12.1 (a5978cd2308)
\
O -- O -- O (45bef56db55)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.idea/vcs.xml | 1 +
README.md | 8 +-
dev/settings.xml | 247 -------------
dev/tencent-install.sh | 158 --------
dev/tencent-release.sh | 155 --------
hudi-cli/pom.xml | 4 +-
hudi-client/hudi-client-common/pom.xml | 7 -
.../apache/hudi/async/AsyncPostEventService.java | 93 -----
.../apache/hudi/client/BaseHoodieWriteClient.java | 28 +-
.../apache/hudi/client/HoodieTimelineArchiver.java | 54 +--
.../lock/metrics/HoodieLockMetrics.java | 19 +-
.../apache/hudi/config/HoodieClusteringConfig.java | 56 +--
.../org/apache/hudi/config/HoodieIndexConfig.java | 63 +---
.../org/apache/hudi/config/HoodieMemoryConfig.java | 9 +-
.../org/apache/hudi/config/HoodieWriteConfig.java | 110 +-----
.../hudi/config/metrics/HoodieMetricsConfig.java | 23 +-
.../config/metrics/HoodieMetricsZhiyanConfig.java | 143 -------
.../java/org/apache/hudi/index/HoodieIndex.java | 2 +-
.../apache/hudi/index/bucket/BucketIdentifier.java | 9 +-
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 28 +-
.../src/main/java/org/apache/hudi/io/IOUtils.java | 14 -
.../apache/hudi/keygen/EmptyAvroKeyGenerator.java | 70 ----
.../java/org/apache/hudi/keygen/KeyGenUtils.java | 39 +-
.../keygen/TimestampBasedAvroKeyGenerator.java | 4 +-
.../metadata/HoodieBackedTableMetadataWriter.java | 11 -
.../org/apache/hudi/metrics/HoodieMetrics.java | 120 +-----
.../main/java/org/apache/hudi/metrics/Metrics.java | 1 -
.../hudi/metrics/MetricsReporterFactory.java | 4 -
.../apache/hudi/metrics/MetricsReporterType.java | 2 +-
.../hudi/metrics/zhiyan/ZhiyanHttpClient.java | 129 -------
.../hudi/metrics/zhiyan/ZhiyanMetricsReporter.java | 60 ---
.../apache/hudi/metrics/zhiyan/ZhiyanReporter.java | 169 ---------
.../hudi/table/action/clean/CleanPlanner.java | 19 +-
.../cluster/ClusteringPlanPartitionFilter.java | 23 --
.../cluster/ClusteringPlanPartitionFilterMode.java | 3 +-
.../PartitionAwareClusteringPlanStrategy.java | 26 +-
.../hudi/table/action/commit/BucketInfo.java | 4 -
.../hudi/table/action/commit/BucketType.java | 2 +-
.../java/org/apache/hudi/tdbank/TDBankClient.java | 103 ------
.../java/org/apache/hudi/tdbank/TdbankConfig.java | 82 -----
.../hudi/tdbank/TdbankHoodieMetricsEvent.java | 110 ------
.../hudi/index/bucket/TestBucketIdentifier.java | 14 +-
.../org/apache/hudi/keygen/TestKeyGenUtils.java | 18 -
.../TestPartitionAwareClusteringPlanStrategy.java | 2 +-
.../apache/hudi/client/HoodieFlinkWriteClient.java | 6 -
.../apache/hudi/index/FlinkHoodieIndexFactory.java | 2 -
.../org/apache/hudi/index/FlinkHoodieNonIndex.java | 65 ----
.../java/org/apache/hudi/io/FlinkMergeHandle.java | 8 +-
.../io/storage/row/HoodieRowDataParquetWriter.java | 4 -
hudi-client/hudi-spark-client/pom.xml | 4 +-
.../apache/hudi/client/SparkRDDWriteClient.java | 22 --
.../SparkSizeBasedClusteringPlanStrategy.java | 14 +-
.../SparkSortAndSizeExecutionStrategy.java | 6 +-
.../apache/hudi/index/SparkHoodieIndexFactory.java | 3 -
.../hudi/index/nonindex/SparkHoodieNonIndex.java | 73 ----
.../hudi/io/storage/row/HoodieRowCreateHandle.java | 5 +-
.../org/apache/hudi/keygen/EmptyKeyGenerator.java | 81 ----
.../commit/BaseSparkCommitActionExecutor.java | 17 -
.../table/action/commit/UpsertPartitioner.java | 35 +-
.../TestSparkSizeBasedClusteringPlanStrategy.java | 94 -----
.../TestSparkClusteringPlanPartitionFilter.java | 29 --
.../java/org/apache/hudi/avro/HoodieAvroUtils.java | 28 --
.../java/org/apache/hudi/common/fs/FSUtils.java | 16 +-
.../common/fs/HoodieRetryWrapperFileSystem.java | 5 -
.../org/apache/hudi/common/model/FileSlice.java | 13 -
.../org/apache/hudi/common/model/HoodieKey.java | 2 -
.../hudi/common/table/HoodieTableConfig.java | 76 +---
.../hudi/common/table/HoodieTableMetaClient.java | 142 +------
.../table/log/AbstractHoodieLogRecordReader.java | 41 +--
.../common/table/log/HoodieLogFormatReader.java | 8 +-
.../common/table/log/HoodieLogFormatWriter.java | 9 +-
.../table/log/HoodieMergedLogRecordScanner.java | 15 +-
.../table/log/block/HoodieHFileDataBlock.java | 7 +-
.../table/timeline/HoodieActiveTimeline.java | 42 +--
.../hudi/common/table/timeline/TimelineUtils.java | 39 +-
.../apache/hudi/common/util/ClusteringUtils.java | 37 --
.../org/apache/hudi/common/util/DateTimeUtils.java | 8 -
.../org/apache/hudi/common/util/FileIOUtils.java | 36 --
.../hudi/common/util/SerializationUtils.java | 39 +-
.../metadata/FileSystemBackedTableMetadata.java | 2 -
hudi-common/src/main/resources/hbase-site.xml | 2 +-
.../fs/TestFSUtilsWithRetryWrapperEnable.java | 14 -
.../hudi/common/table/TestHoodieTableConfig.java | 21 --
.../hudi/common/table/TestTimelineUtils.java | 101 +----
.../hudi/common/util/TestClusteringUtils.java | 69 ----
.../hudi/common/util/TestSerializationUtils.java | 29 +-
hudi-examples/hudi-examples-spark/pom.xml | 4 +-
.../apache/hudi/configuration/FlinkOptions.java | 57 +--
.../apache/hudi/configuration/OptionsResolver.java | 4 -
.../org/apache/hudi/sink/StreamWriteFunction.java | 38 +-
.../hudi/sink/StreamWriteOperatorCoordinator.java | 47 +--
.../hudi/sink/append/AppendWriteFunction.java | 2 +-
.../sink/bucket/BucketStreamWriteFunction.java | 10 +-
.../hudi/sink/bulk/BulkInsertWriteFunction.java | 10 +-
.../hudi/sink/clustering/ClusteringOperator.java | 63 ++--
.../sink/clustering/FlinkClusteringConfig.java | 37 +-
.../sink/common/AbstractStreamWriteFunction.java | 23 +-
.../hudi/sink/common/AbstractWriteFunction.java | 103 ------
.../hudi/sink/common/AbstractWriteOperator.java | 9 -
.../hudi/sink/compact/FlinkCompactionConfig.java | 30 +-
.../apache/hudi/sink/event/WriteMetadataEvent.java | 31 +-
.../org/apache/hudi/sink/meta/CkpMetadata.java | 7 +-
.../sink/nonindex/NonIndexStreamWriteFunction.java | 265 -------------
.../sink/nonindex/NonIndexStreamWriteOperator.java | 40 --
.../sink/partitioner/BucketIndexPartitioner.java | 5 +-
.../apache/hudi/sink/utils/NonThrownExecutor.java | 8 +-
.../java/org/apache/hudi/sink/utils/Pipelines.java | 7 -
.../apache/hudi/source/IncrementalInputSplits.java | 47 +--
.../hudi/source/StreamReadMonitoringFunction.java | 34 +-
.../apache/hudi/streamer/FlinkStreamerConfig.java | 57 +--
.../apache/hudi/streamer/HoodieFlinkStreamer.java | 25 +-
.../org/apache/hudi/table/HoodieTableFactory.java | 21 --
.../org/apache/hudi/table/HoodieTableSource.java | 42 +--
.../table/format/mor/MergeOnReadInputFormat.java | 29 --
.../table/format/mor/MergeOnReadInputSplit.java | 8 +-
.../java/org/apache/hudi/util/ClusteringUtil.java | 19 -
.../java/org/apache/hudi/util/DataTypeUtils.java | 141 -------
.../java/org/apache/hudi/util/HoodiePipeline.java | 14 -
.../org/apache/hudi/util/RowDataProjection.java | 21 +-
.../java/org/apache/hudi/util/StreamerUtil.java | 47 +--
.../apache/hudi/sink/ITTestDataStreamWrite.java | 35 --
.../sink/TestStreamWriteOperatorCoordinator.java | 16 -
.../sink/TestWriteFunctionEventTimeExtract.java | 232 ------------
.../org/apache/hudi/sink/TestWriteMergeOnRead.java | 54 ---
.../hudi/sink/utils/InsertFunctionWrapper.java | 6 -
.../sink/utils/StreamWriteFunctionWrapper.java | 24 +-
.../apache/hudi/sink/utils/TestDataTypeUtils.java | 45 ---
.../hudi/sink/utils/TestFunctionWrapper.java | 6 -
.../org/apache/hudi/sink/utils/TestWriteBase.java | 48 ---
.../apache/hudi/table/ITTestHoodieDataSource.java | 42 +--
.../test/java/org/apache/hudi/utils/TestData.java | 34 --
.../hudi/utils/source/ContinuousFileSource.java | 5 -
.../realtime/AbstractRealtimeRecordReader.java | 72 +---
.../realtime/HoodieHFileRealtimeInputFormat.java | 2 +-
.../realtime/HoodieParquetRealtimeInputFormat.java | 14 +-
.../realtime/RealtimeCompactedRecordReader.java | 25 +-
.../hudi/hadoop/utils/HiveAvroSerializer.java | 409 ---------------------
.../utils/HoodieRealtimeInputFormatUtils.java | 19 +-
.../utils/HoodieRealtimeRecordReaderUtils.java | 5 -
.../hudi/hadoop/utils/TestHiveAvroSerializer.java | 148 --------
hudi-integ-test/pom.xml | 4 +-
hudi-spark-datasource/hudi-spark-common/pom.xml | 12 +-
.../main/java/org/apache/hudi/DataSourceUtils.java | 15 +-
.../scala/org/apache/hudi/HoodieCLIUtils.scala | 2 +-
.../org/apache/hudi/HoodieSparkSqlWriter.scala | 26 +-
.../spark/sql/hudi/HoodieSqlCommonUtils.scala | 6 +-
.../AlterHoodieTableAddColumnsCommand.scala | 1 -
.../sql/hudi/command/DropHoodieTableCommand.scala | 13 +-
.../command/ShowHoodieTablePropertiesCommand.scala | 61 ---
hudi-spark-datasource/hudi-spark/pom.xml | 12 +-
.../hudi/spark/sql/parser/HoodieSqlCommon.g4 | 6 +-
.../spark/sql/hudi/analysis/HoodieAnalysis.scala | 1 -
.../hudi/command/MergeIntoHoodieTableCommand.scala | 3 +-
.../procedures/BackupInvalidParquetProcedure.scala | 111 ------
.../hudi/command/procedures/BaseProcedure.scala | 4 +-
.../hudi/command/procedures/CopyToTempView.scala | 114 ------
.../command/procedures/DeleteFsFileProcedure.scala | 80 ----
.../DeleteRollbackInstantProcedure.scala | 73 ----
.../procedures/DropPartitionsProcedure.scala | 118 ------
.../hudi/command/procedures/HelpProcedure.scala | 125 -------
.../hudi/command/procedures/HoodieProcedures.scala | 12 -
.../procedures/RunClusteringProcedure.scala | 168 +++------
.../ShowCommitExtraMetadataProcedure.scala | 138 -------
.../procedures/ShowCompactionProcedure.scala | 2 +-
.../procedures/ShowTablePropertiesProcedure.scala | 71 ----
.../sql/parser/HoodieSqlCommonAstBuilder.scala | 21 +-
.../java/org/apache/hudi/TestDataSourceUtils.java | 2 +-
.../org/apache/hudi/TestHoodieSparkSqlWriter.scala | 5 +-
.../test/scala/org/apache/hudi/TestNonIndex.scala | 110 ------
.../hudi/functional/TestLayoutOptimization.scala | 3 +-
.../spark/sql/hudi/TestCompactionTable.scala | 6 +-
.../apache/spark/sql/hudi/TestInsertTable.scala | 142 +------
.../org/apache/spark/sql/hudi/TestSpark3DDL.scala | 9 -
.../TestBackupInvalidParquetProcedure.scala | 88 -----
.../hudi/procedure/TestClusteringProcedure.scala | 339 +----------------
.../sql/hudi/procedure/TestCommitsProcedure.scala | 54 +--
.../hudi/procedure/TestCompactionProcedure.scala | 38 +-
.../procedure/TestCopyToTempViewProcedure.scala | 168 ---------
.../hudi/procedure/TestDeleteFsFileProcedure.scala | 47 ---
.../TestDeleteRollbackInstantProcedure.scala | 89 -----
.../procedure/TestDropPartitionsProcedure.scala | 67 ----
.../sql/hudi/procedure/TestHelpProcedure.scala | 84 -----
.../TestShowTablePropertiesProcedure.scala | 45 ---
hudi-spark-datasource/hudi-spark2/pom.xml | 12 +-
.../org/apache/hudi/internal/DefaultSource.java | 1 -
hudi-spark-datasource/hudi-spark3-common/pom.xml | 2 +-
.../apache/hudi/spark3/internal/DefaultSource.java | 4 +-
hudi-spark-datasource/hudi-spark3.1.x/pom.xml | 2 +-
.../datasources/Spark31NestedSchemaPruning.scala | 24 +-
.../parquet/Spark31HoodieParquetFileFormat.scala | 20 +-
.../hudi/command/Spark31AlterTableCommand.scala | 33 +-
hudi-spark-datasource/hudi-spark3.2.x/pom.xml | 6 +-
.../sql/hudi/analysis/HoodieSpark3Analysis.scala | 6 +-
.../spark/sql/hudi/command/AlterTableCommand.scala | 35 +-
hudi-spark-datasource/hudi-spark3.3.x/pom.xml | 6 +-
hudi-sync/hudi-hive-sync/pom.xml | 4 +-
.../apache/hudi/sync/common/HoodieSyncClient.java | 12 +-
hudi-utilities/pom.xml | 10 +-
.../org/apache/hudi/utilities/UtilHelpers.java | 38 +-
packaging/hudi-integ-test-bundle/pom.xml | 8 +-
pom.xml | 134 +++----
201 files changed, 634 insertions(+), 8279 deletions(-)
delete mode 100644 dev/settings.xml
delete mode 100644 dev/tencent-install.sh
delete mode 100644 dev/tencent-release.sh
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/async/AsyncPostEventService.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsZhiyanConfig.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/EmptyAvroKeyGenerator.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/zhiyan/ZhiyanHttpClient.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/zhiyan/ZhiyanMetricsReporter.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/zhiyan/ZhiyanReporter.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/tdbank/TDBankClient.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/tdbank/TdbankConfig.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/tdbank/TdbankHoodieMetricsEvent.java
delete mode 100644 hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieNonIndex.java
delete mode 100644 hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/nonindex/SparkHoodieNonIndex.java
delete mode 100644 hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/EmptyKeyGenerator.java
delete mode 100644 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/clustering/plan/strategy/TestSparkSizeBasedClusteringPlanStrategy.java
delete mode 100644 hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/nonindex/NonIndexStreamWriteFunction.java
delete mode 100644 hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/nonindex/NonIndexStreamWriteOperator.java
delete mode 100644 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteFunctionEventTimeExtract.java
delete mode 100644 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/TestDataTypeUtils.java
delete mode 100644 hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HiveAvroSerializer.java
delete mode 100644 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/utils/TestHiveAvroSerializer.java
delete mode 100644 hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/ShowHoodieTablePropertiesCommand.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/BackupInvalidParquetProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/CopyToTempView.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/DeleteFsFileProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/DeleteRollbackInstantProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/DropPartitionsProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HelpProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCommitExtraMetadataProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowTablePropertiesProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestNonIndex.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestBackupInvalidParquetProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCopyToTempViewProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestDeleteFsFileProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestDeleteRollbackInstantProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestDropPartitionsProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestHelpProcedure.scala
delete mode 100644 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestShowTablePropertiesProcedure.scala