This is an automated email from the ASF dual-hosted git repository.
yihua pushed a change to branch branch-0.x
in repository https://gitbox.apache.org/repos/asf/hudi.git
from c56fed9620d [HUDI-7587] Make hudi-hadoop-common module dependent on
hudi-common module (#11131)
new 9e35710f3be [HUDI-7350] Make Hudi reader and writer factory APIs
Hadoop-independent (#11163)
new 91e76854ab4 [HUDI-7725] Restructure HFileBootstrapIndex to separate
Hadoop-dependent logic (#11171)
new 223588c7071 [HUDI-7729] Move ParquetUtils to hudi-hadoop-common module
(#11186)
new 83ee6cf493d [HUDI-7738] Set FileStreamReader Charset as UTF-8 (#11181)
new 6d35691b6a8 [HUDI-7654] Optimizing BQ sync for MDT (#11061)
new 09baac5e133 [HUDI-7726] Restructure TableSchemaResolver to separate
Hadoop logic and use BaseFileUtils (#11185)
new e987c8a8512 [HUDI-7742] Move Hadoop-dependent reader util classes to
hudi-hadoop-common module (#11190)
new ed0462b49ad [HUDI-7673] Fixing false positive validation failure for
RLI with MDT validation tool (#11098)
new aacbdc7da5b [HUDI-7731] Fix usage of new Configuration() in production
code (#11191)
new 21874a3f5ad [HUDI-7739] Shudown asyncDetectorExecutor in
AsyncTimelineServerBasedDetectionStrategy (#11182)
new 460d90e50fa [HUDI-7508] Avoid collecting records in
HoodieStreamerUtils.createHoodieRecords and JsonKafkaSource mapPartitions
(#10872)
new 1536d50870a [HUDI-7745] Move Hadoop-dependent util methods to
hudi-hadoop-common (#11193)
new cb921e9704e [HUDI-4732] Add support for confluent schema registry with
proto (#11070)
new 0b75508a22e [HUDI-7501] Use source profile for S3 and GCS sources
(#10861)
The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../hudi/aws/sync/AWSGlueCatalogSyncClient.java | 4 +-
.../apache/hudi/cli/commands/BootstrapCommand.java | 2 +-
.../hudi/cli/commands/HoodieLogFileCommand.java | 15 +-
.../apache/hudi/cli/utils/InputStreamConsumer.java | 3 +-
.../org/apache/hudi/client/BaseHoodieClient.java | 2 +-
.../hudi/client/transaction/lock/LockManager.java | 2 +-
.../lock/metrics/HoodieLockMetrics.java | 5 +-
.../hudi/client/utils/CommitMetadataUtils.java | 4 +-
.../apache/hudi/config/HoodieBootstrapConfig.java | 2 +-
.../index/bucket/ConsistentBucketIndexUtils.java | 5 +-
.../org/apache/hudi/io/HoodieAppendHandle.java | 3 +-
.../java/org/apache/hudi/io/HoodieCDCLogger.java | 4 +-
.../org/apache/hudi/io/HoodieCreateHandle.java | 3 +-
.../hudi/io/HoodieKeyLocationFetchHandle.java | 7 +-
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 3 +-
.../org/apache/hudi/metrics/HoodieMetrics.java | 5 +-
.../table/action/bootstrap/BootstrapUtils.java | 11 +-
.../compact/RunCompactionActionExecutor.java | 2 +-
.../table/action/index/RunIndexActionExecutor.java | 2 +-
.../table/action/rollback/BaseRollbackHelper.java | 5 +-
.../rollback/ListingBasedRollbackStrategy.java | 9 +-
.../rollback/MarkerBasedRollbackStrategy.java | 7 +-
.../hudi/avro/TestHoodieAvroParquetWriter.java | 4 +-
.../hudi/metrics/TestHoodieConsoleMetrics.java | 5 +-
.../hudi/metrics/TestHoodieGraphiteMetrics.java | 5 +-
.../apache/hudi/metrics/TestHoodieJmxMetrics.java | 5 +-
.../org/apache/hudi/metrics/TestHoodieMetrics.java | 5 +-
.../datadog/TestDatadogMetricsReporter.java | 9 +-
.../org/apache/hudi/metrics/m3/TestM3Metrics.java | 10 +-
.../metrics/prometheus/TestPrometheusReporter.java | 7 +-
.../prometheus/TestPushGateWayReporter.java | 13 +-
.../hudi/testutils/HoodieWriteableTestTable.java | 10 +-
.../row/HoodieRowDataFileWriterFactory.java | 3 +-
.../io/storage/row/HoodieRowDataParquetWriter.java | 2 +-
.../FlinkHoodieBackedTableMetadataWriter.java | 2 +-
.../JavaHoodieBackedTableMetadataWriter.java | 2 +-
.../hudi/client/TestJavaHoodieBackedMetadata.java | 14 +-
.../testutils/HoodieJavaClientTestHarness.java | 10 +-
.../HoodieSparkBootstrapSchemaProvider.java | 4 +-
.../client/validator/SparkPreCommitValidator.java | 2 +-
.../io/storage/HoodieSparkFileWriterFactory.java | 5 +-
.../hudi/io/storage/HoodieSparkParquetWriter.java | 1 +
.../row/HoodieInternalRowFileWriterFactory.java | 3 +-
.../row/HoodieInternalRowParquetWriter.java | 2 +-
.../io/storage/row/HoodieRowParquetConfig.java | 8 +-
.../SparkHoodieBackedTableMetadataWriter.java | 2 +-
.../bootstrap/MetadataBootstrapHandlerFactory.java | 9 +-
.../bootstrap/OrcBootstrapMetadataHandler.java | 2 +-
.../functional/TestHoodieBackedMetadata.java | 14 +-
.../functional/TestHoodieBackedTableMetadata.java | 7 +-
.../storage/TestHoodieAvroFileWriterFactory.java | 3 +
.../java/org/apache/hudi/table/TestCleaner.java | 7 +-
...dieSparkMergeOnReadTableInsertUpdateDelete.java | 3 +-
.../hudi/testutils/HoodieCleanerTestBase.java | 2 +-
.../hudi/common/bootstrap/FileStatusUtils.java | 86 ---
.../common/bootstrap/index/BootstrapIndex.java | 13 +-
.../bootstrap/index/HFileBootstrapIndex.java | 783 ---------------------
.../common/bootstrap/index/NoOpBootstrapIndex.java | 13 +-
.../bootstrap/index/hfile/HFileBootstrapIndex.java | 174 +++++
.../index/hfile/HFileBootstrapIndexReader.java | 242 +++++++
.../TimelineServerBasedDetectionStrategy.java | 2 +
.../java/org/apache/hudi/common/fs/FSUtils.java | 229 +-----
.../hudi/common/model/HoodiePartitionMetadata.java | 2 +-
.../hudi/common/table/HoodieTableConfig.java | 2 +-
.../hudi/common/table/TableSchemaResolver.java | 122 +---
.../common/table/log/HoodieLogFormatWriter.java | 2 +-
.../table/log/block/HoodieAvroDataBlock.java | 3 +-
.../common/table/log/block/HoodieCommandBlock.java | 3 +-
.../common/table/log/block/HoodieCorruptBlock.java | 3 +-
.../common/table/log/block/HoodieDataBlock.java | 7 +-
.../common/table/log/block/HoodieDeleteBlock.java | 3 +-
.../table/log/block/HoodieHFileDataBlock.java | 15 +-
.../common/table/log/block/HoodieLogBlock.java | 2 +-
.../table/log/block/HoodieParquetDataBlock.java | 58 +-
.../org/apache/hudi/common/util/BaseFileUtils.java | 30 +-
.../org/apache/hudi/common/util/ConfigUtils.java | 57 --
.../hudi/io/storage/HoodieAvroFileReader.java | 28 +-
.../hudi/io/storage/HoodieAvroFileReaderBase.java | 48 --
.../io/storage/HoodieAvroHFileReaderImplBase.java | 39 +-
.../hudi/io/storage/HoodieFileReaderFactory.java | 11 +-
.../hudi/io/storage/HoodieFileWriterFactory.java | 21 +-
.../apache/hudi/io/storage/HoodieOrcConfig.java | 15 +-
.../hudi/io/storage/HoodieParquetConfig.java | 15 +-
.../apache/hudi/metadata/BaseTableMetadata.java | 3 +-
.../hudi/metadata/HoodieMetadataMetrics.java | 5 +-
.../hudi/metadata/HoodieTableMetadataUtil.java | 8 +-
.../main/java/org/apache/hudi/metrics/Metrics.java | 12 +-
.../common/testutils/HoodieTestDataGenerator.java | 4 -
.../apache/hudi/common/util/TestConfigUtils.java | 10 +-
.../io/storage/TestHoodieReaderWriterUtils.java | 2 +-
.../hudi/table/catalog/TableOptionProperties.java | 4 +-
.../sink/compact/ITTestHoodieFlinkCompactor.java | 3 +-
.../bootstrap/index/HFileBootstrapIndex.java | 15 +-
.../hfile/HBaseHFileBootstrapIndexReader.java | 283 ++++++++
.../hfile/HBaseHFileBootstrapIndexWriter.java | 228 ++++++
.../common/config/DFSPropertiesConfiguration.java | 5 +-
.../common/table/ParquetTableSchemaResolver.java | 66 ++
.../org/apache/hudi/common/util/AvroOrcUtils.java | 0
.../org/apache/hudi/common/util/HFileUtils.java | 129 ++++
.../apache/hudi/common/util/HadoopConfigUtils.java | 91 +++
.../java/org/apache/hudi/common/util/OrcUtils.java | 8 +
.../org/apache/hudi/common/util/ParquetUtils.java | 116 ++-
.../org/apache/hudi/hadoop/fs/HadoopFSUtils.java | 275 ++++++++
.../io/hadoop}/HoodieAvroFileReaderFactory.java | 48 +-
.../io/hadoop}/HoodieAvroFileWriterFactory.java | 45 +-
.../{storage => hadoop}/HoodieAvroHFileWriter.java | 17 +-
.../hudi/io/hadoop}/HoodieAvroOrcReader.java | 22 +-
.../{storage => hadoop}/HoodieAvroOrcWriter.java | 19 +-
.../hudi/io/hadoop}/HoodieAvroParquetReader.java | 21 +-
.../HoodieAvroParquetWriter.java | 17 +-
.../HoodieBaseParquetWriter.java | 23 +-
.../io/hadoop}/HoodieHBaseAvroHFileReader.java | 33 +-
.../apache/hudi/io/hadoop}/HoodieHFileConfig.java | 16 +-
.../apache/hudi/io/hadoop}/HoodieHFileUtils.java | 40 +-
.../hudi/io/hadoop}/HoodieParquetStreamWriter.java | 19 +-
.../apache/hudi/io/hadoop}/OrcReaderIterator.java | 17 +-
.../hudi/io/storage/HoodieHBaseKVComparator.java | 0
.../parquet/io/OutputStreamBackedOutputFile.java | 0
.../avro/HoodieAvroParquetReaderBuilder.java | 0
.../apache/parquet/avro/HoodieAvroReadSupport.java | 0
.../bootstrap/{ => index}/TestBootstrapIndex.java | 19 +-
.../org/apache/hudi/common/fs/TestFSUtils.java | 6 +-
.../TestInLineFileSystemWithHBaseHFileReader.java | 2 +-
.../common/functional/TestHoodieLogFormat.java | 2 +-
.../hudi/common/table/TestTableSchemaResolver.java | 7 +-
.../table/log/block/TestHoodieDeleteBlock.java | 3 +-
.../table/view/TestHoodieTableFileSystemView.java | 8 +-
.../hudi/common/testutils/HoodieTestTable.java | 3 +-
.../apache/hudi/common/util/TestAvroOrcUtils.java | 4 +
.../hudi/common/util/TestHadoopConfigUtils.java | 63 ++
.../apache/hudi/common/util/TestParquetUtils.java | 115 +++
.../TestHoodieAvroFileReaderFactory.java | 17 +-
.../TestHoodieBaseParquetWriter.java | 23 +-
.../TestHoodieHBaseHFileReaderWriter.java | 25 +-
.../TestHoodieHFileReaderWriter.java | 18 +-
.../TestHoodieHFileReaderWriterBase.java | 7 +-
.../TestHoodieOrcReaderWriter.java | 21 +-
.../TestHoodieReaderWriterBase.java | 6 +-
.../hudi/io/hadoop}/TestOrcReaderIterator.java | 17 +-
.../hudi/hadoop/HoodieROTablePathFilter.java | 3 +-
.../realtime/HoodieParquetRealtimeInputFormat.java | 3 +-
.../hudi/hadoop/utils/HoodieInputFormatUtils.java | 2 +-
.../TestHoodieMergeOnReadSnapshotReader.java | 3 +-
.../realtime/TestHoodieRealtimeRecordReader.java | 3 +-
.../SparkFullBootstrapDataProviderBase.java | 4 +-
.../org/apache/spark/sql/hudi/SparkHelpers.scala | 7 +-
.../RepairOverwriteHoodiePropsProcedure.scala | 2 +-
.../command/procedures/RunBootstrapProcedure.scala | 2 +-
.../ShowHoodieLogFileMetadataProcedure.scala | 3 +-
.../ShowHoodieLogFileRecordsProcedure.scala | 9 +-
.../procedures/ShowInvalidParquetProcedure.scala | 2 +-
.../org/apache/hudi/ColumnStatsIndexHelper.java | 2 +-
.../org/apache/hudi/functional/TestBootstrap.java | 9 +-
.../apache/hudi/functional/TestOrcBootstrap.java | 12 +-
.../row/TestHoodieInternalRowParquetWriter.java | 3 +-
.../hudi/functional/TestColumnStatsIndex.scala | 2 +-
.../TestMetadataTableWithSparkDataSource.scala | 5 +-
.../apache/hudi/sync/adb/HoodieAdbJdbcClient.java | 12 +-
.../org/apache/hudi/hive/ddl/HMSDDLExecutor.java | 7 +-
.../hudi/hive/ddl/QueryBasedDDLExecutor.java | 7 +-
.../org/apache/hudi/hive/TestHiveSyncTool.java | 4 +-
.../apache/hudi/sync/common/HoodieSyncClient.java | 10 +-
.../apache/hudi/sync/common/HoodieSyncConfig.java | 4 +-
.../apache/hudi/sync/common/HoodieSyncTool.java | 4 +-
.../hudi/sync/common/util/ManifestFileWriter.java | 51 +-
.../hudi/timeline/service/RequestHandler.java | 9 +-
.../timeline/service/handlers/MarkerHandler.java | 3 +
.../AsyncTimelineServerBasedDetectionStrategy.java | 6 +
.../MarkerBasedEarlyConflictDetectionRunnable.java | 6 +-
hudi-utilities/pom.xml | 7 +-
.../hudi/utilities/HoodieDataTableUtils.java | 2 +-
.../utilities/HoodieMetadataTableValidator.java | 130 ++--
.../apache/hudi/utilities/HoodieRepairTool.java | 7 +-
.../hudi/utilities/HoodieSnapshotCopier.java | 2 +-
.../hudi/utilities/HoodieSnapshotExporter.java | 2 +-
.../hudi/utilities/HoodieWithTimelineServer.java | 3 +-
.../org/apache/hudi/utilities/TableSizeStats.java | 3 +-
.../org/apache/hudi/utilities/UtilHelpers.java | 53 +-
.../hudi/utilities/config/KafkaSourceConfig.java | 8 +
.../deltastreamer/HoodieDeltaStreamerMetrics.java | 9 +-
.../deser/KafkaAvroSchemaDeserializer.java | 4 +-
.../ingestion/HoodieIngestionMetrics.java | 10 +-
.../schema/ProtoClassBasedSchemaProvider.java | 10 +-
.../ProtoSchemaToAvroSchemaConverter.java | 43 ++
.../sources/GcsEventsHoodieIncrSource.java | 61 +-
.../hudi/utilities/sources/HoodieIncrSource.java | 6 +-
.../hudi/utilities/sources/JsonKafkaSource.java | 18 +-
.../hudi/utilities/sources/ProtoKafkaSource.java | 40 +-
.../apache/hudi/utilities/sources/RowSource.java | 8 +-
.../sources/S3EventsHoodieIncrSource.java | 87 +--
.../sources/helpers/CloudDataFetcher.java | 79 ++-
.../helpers/CloudObjectsSelectorCommon.java | 70 +-
.../sources/helpers/ProtoConversionUtil.java | 56 +-
.../helpers/gcs/GcsObjectMetadataFetcher.java | 86 ---
.../hudi/utilities/streamer/HoodieStreamer.java | 2 +-
.../utilities/streamer/HoodieStreamerMetrics.java | 11 +-
.../utilities/streamer/HoodieStreamerUtils.java | 20 +-
.../apache/hudi/utilities/streamer/StreamSync.java | 8 +-
.../TestHoodieMetadataTableValidator.java | 118 +++-
.../utilities/TestManifestFileWriterSpark.java | 117 +++
.../deltastreamer/HoodieDeltaStreamerTestBase.java | 3 +-
.../deser/TestKafkaAvroSchemaDeserializer.java | 8 +-
.../TestProtoSchemaToAvroSchemaConverter.java | 50 ++
.../sources/TestGcsEventsHoodieIncrSource.java | 83 ++-
.../utilities/sources/TestHoodieIncrSource.java | 3 +-
.../utilities/sources/TestProtoKafkaSource.java | 63 +-
.../sources/TestS3EventsHoodieIncrSource.java | 125 +++-
.../debezium/TestAbstractDebeziumSource.java | 3 +-
.../helpers/TestCloudObjectsSelectorCommon.java | 42 +-
.../utilities/testutils/UtilitiesTestBase.java | 3 +-
packaging/hudi-utilities-bundle/pom.xml | 1 +
packaging/hudi-utilities-slim-bundle/pom.xml | 1 +
pom.xml | 34 +-
213 files changed, 3605 insertions(+), 2376 deletions(-)
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/hfile/HFileBootstrapIndex.java
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/hfile/HFileBootstrapIndexReader.java
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReaderBase.java
copy
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHBaseKVComparator.java
=>
hudi-hadoop-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java
(62%)
create mode 100644
hudi-hadoop-common/src/main/java/org/apache/hudi/common/bootstrap/index/hfile/HBaseHFileBootstrapIndexReader.java
create mode 100644
hudi-hadoop-common/src/main/java/org/apache/hudi/common/bootstrap/index/hfile/HBaseHFileBootstrapIndexWriter.java
create mode 100644
hudi-hadoop-common/src/main/java/org/apache/hudi/common/table/ParquetTableSchemaResolver.java
rename {hudi-common =>
hudi-hadoop-common}/src/main/java/org/apache/hudi/common/util/AvroOrcUtils.java
(100%)
create mode 100644
hudi-hadoop-common/src/main/java/org/apache/hudi/common/util/HFileUtils.java
create mode 100644
hudi-hadoop-common/src/main/java/org/apache/hudi/common/util/HadoopConfigUtils.java
rename {hudi-common =>
hudi-hadoop-common}/src/main/java/org/apache/hudi/common/util/ParquetUtils.java
(89%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieAvroFileReaderFactory.java
(58%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieAvroFileWriterFactory.java
(80%)
rename hudi-hadoop-common/src/main/java/org/apache/hudi/io/{storage =>
hadoop}/HoodieAvroHFileWriter.java (93%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieAvroOrcReader.java
(83%)
rename hudi-hadoop-common/src/main/java/org/apache/hudi/io/{storage =>
hadoop}/HoodieAvroOrcWriter.java (91%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieAvroParquetReader.java
(92%)
rename hudi-hadoop-common/src/main/java/org/apache/hudi/io/{storage =>
hadoop}/HoodieAvroParquetWriter.java (84%)
rename hudi-hadoop-common/src/main/java/org/apache/hudi/io/{storage =>
hadoop}/HoodieBaseParquetWriter.java (90%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieHBaseAvroHFileReader.java
(95%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieHFileConfig.java
(87%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieHFileUtils.java
(80%)
rename {hudi-common/src/main/java/org/apache/hudi/io/storage =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/HoodieParquetStreamWriter.java
(84%)
rename {hudi-common/src/main/java/org/apache/hudi/common/util =>
hudi-hadoop-common/src/main/java/org/apache/hudi/io/hadoop}/OrcReaderIterator.java
(87%)
rename {hudi-common =>
hudi-hadoop-common}/src/main/java/org/apache/hudi/io/storage/HoodieHBaseKVComparator.java
(100%)
rename {hudi-common =>
hudi-hadoop-common}/src/main/java/org/apache/hudi/parquet/io/OutputStreamBackedOutputFile.java
(100%)
rename {hudi-common =>
hudi-hadoop-common}/src/main/java/org/apache/parquet/avro/HoodieAvroParquetReaderBuilder.java
(100%)
rename {hudi-common =>
hudi-hadoop-common}/src/main/java/org/apache/parquet/avro/HoodieAvroReadSupport.java
(100%)
rename hudi-hadoop-common/src/test/java/org/apache/hudi/common/bootstrap/{ =>
index}/TestBootstrapIndex.java (93%)
rename {hudi-common =>
hudi-hadoop-common}/src/test/java/org/apache/hudi/common/table/log/block/TestHoodieDeleteBlock.java
(97%)
create mode 100644
hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestHadoopConfigUtils.java
rename hudi-hadoop-common/src/test/java/org/apache/hudi/io/{storage =>
hadoop}/TestHoodieAvroFileReaderFactory.java (83%)
rename hudi-hadoop-common/src/test/java/org/apache/hudi/io/{storage =>
hadoop}/TestHoodieBaseParquetWriter.java (86%)
rename hudi-hadoop-common/src/test/java/org/apache/hudi/io/{storage =>
hadoop}/TestHoodieHBaseHFileReaderWriter.java (87%)
rename hudi-hadoop-common/src/test/java/org/apache/hudi/io/{storage =>
hadoop}/TestHoodieHFileReaderWriter.java (85%)
rename hudi-hadoop-common/src/test/java/org/apache/hudi/io/{storage =>
hadoop}/TestHoodieHFileReaderWriterBase.java (98%)
rename hudi-hadoop-common/src/test/java/org/apache/hudi/io/{storage =>
hadoop}/TestHoodieOrcReaderWriter.java (87%)
rename hudi-hadoop-common/src/test/java/org/apache/hudi/io/{storage =>
hadoop}/TestHoodieReaderWriterBase.java (97%)
rename {hudi-common/src/test/java/org/apache/hudi/common/util =>
hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop}/TestOrcReaderIterator.java
(88%)
create mode 100644
hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/converter/ProtoSchemaToAvroSchemaConverter.java
delete mode 100644
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/GcsObjectMetadataFetcher.java
create mode 100644
hudi-utilities/src/test/java/org/apache/hudi/utilities/TestManifestFileWriterSpark.java
create mode 100644
hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/converter/TestProtoSchemaToAvroSchemaConverter.java
