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 e1da06fa70 [MINOR] Typo fix for kryo in flink-bundle (#6639)
add 13eb892081 [HUDI-4811] Fix the checkstyle of hudi flink (#6633)
No new revisions were added by this update.
Summary of changes:
hudi-client/hudi-flink-client/pom.xml | 561 +++++++++++----------
.../hudi/client/FlinkTaskContextSupplier.java | 2 +-
.../apache/hudi/client/HoodieFlinkWriteClient.java | 8 +
.../client/common/HoodieFlinkEngineContext.java | 7 +-
.../hudi/execution/FlinkLazyInsertIterable.java | 5 +
.../java/org/apache/hudi/io/MiniBatchHandle.java | 3 +-
.../io/storage/row/HoodieRowDataParquetWriter.java | 2 +-
.../row/parquet/ParquetSchemaConverter.java | 5 +-
.../FlinkHoodieBackedTableMetadataWriter.java | 3 +
.../hudi/table/ExplicitWriteHandleTable.java | 22 +-
.../hudi/table/HoodieFlinkCopyOnWriteTable.java | 23 +-
.../hudi/table/HoodieFlinkMergeOnReadTable.java | 3 +
.../org/apache/hudi/table/HoodieFlinkTable.java | 3 +
.../commit/FlinkDeleteCommitActionExecutor.java | 3 +
.../table/action/commit/FlinkDeleteHelper.java | 3 +
.../commit/FlinkInsertCommitActionExecutor.java | 3 +
.../FlinkInsertOverwriteCommitActionExecutor.java | 3 +
...nkInsertOverwriteTableCommitActionExecutor.java | 3 +
.../FlinkInsertPreppedCommitActionExecutor.java | 3 +
.../hudi/table/action/commit/FlinkMergeHelper.java | 3 +
.../commit/FlinkUpsertCommitActionExecutor.java | 3 +
.../FlinkUpsertPreppedCommitActionExecutor.java | 3 +
.../delta/BaseFlinkDeltaCommitActionExecutor.java | 3 +
.../FlinkUpsertDeltaCommitActionExecutor.java | 3 +
...linkUpsertPreppedDeltaCommitActionExecutor.java | 3 +
.../common/TestHoodieFlinkEngineContext.java | 2 +-
.../index/bloom/TestFlinkHoodieBloomIndex.java | 13 +-
.../testutils/HoodieFlinkClientTestHarness.java | 9 +-
.../testutils/HoodieFlinkWriteableTestTable.java | 5 +-
.../apache/hudi/configuration/FlinkOptions.java | 2 +-
.../hudi/configuration/HadoopConfigurations.java | 2 +-
.../sink/clustering/FlinkClusteringConfig.java | 10 +-
.../sink/clustering/HoodieFlinkClusteringJob.java | 2 +-
.../hudi/sink/compact/CompactionPlanOperator.java | 2 +-
.../hudi/sink/compact/HoodieFlinkCompactor.java | 2 +-
.../java/org/apache/hudi/sink/utils/Pipelines.java | 18 +-
.../hudi/source/stats/ExpressionEvaluator.java | 1 +
.../apache/hudi/streamer/FlinkStreamerConfig.java | 4 +-
.../org/apache/hudi/table/HoodieTableSource.java | 2 +-
.../apache/hudi/table/catalog/HiveSchemaUtils.java | 16 +-
.../hudi/table/catalog/HoodieHiveCatalog.java | 2 +-
.../org/apache/hudi/util/AvroSchemaConverter.java | 2 +-
.../java/org/apache/hudi/util/ClusteringUtil.java | 2 +-
.../java/org/apache/hudi/util/CompactionUtil.java | 2 +-
.../java/org/apache/hudi/util/DataTypeUtils.java | 2 +-
.../hudi/util/FlinkStateBackendConverter.java | 6 +-
.../java/org/apache/hudi/util/HoodiePipeline.java | 62 +--
.../java/org/apache/hudi/util/StreamerUtil.java | 4 +-
.../apache/hudi/sink/ITTestDataStreamWrite.java | 4 +-
.../org/apache/hudi/sink/TestWriteMergeOnRead.java | 52 +-
.../sink/compact/ITTestHoodieFlinkCompactor.java | 2 +-
.../sink/compact/TestCompactionPlanStrategy.java | 39 +-
.../hudi/source/stats/TestExpressionEvaluator.java | 2 +-
.../apache/hudi/table/ITTestHoodieDataSource.java | 4 +-
.../hudi/table/catalog/HoodieCatalogTestUtils.java | 8 +-
.../table/catalog/TestHoodieCatalogFactory.java | 2 +-
.../hudi/table/catalog/TestHoodieHiveCatalog.java | 4 +-
.../test/java/org/apache/hudi/utils/TestData.java | 16 +-
.../hudi-flink/src/test/resources/hive-site.xml | 16 +-
.../test-catalog-factory-conf/hive-site.xml | 10 +-
.../format/cow/vector/HeapMapColumnVector.java | 2 +-
61 files changed, 546 insertions(+), 470 deletions(-)
