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 2022/05/13 01:50:17 UTC
[hudi] branch master updated (0cec955fa2 -> 701f8c039d)

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 0cec955fa2 [HUDI-4018][HUDI-4027] Adding integ test yamls for immutable use-cases. Added delete partition support to integ tests (#5501)
     add 701f8c039d [HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink (#5528)

No new revisions were added by this update.

Summary of changes:
 .../apache/hudi/configuration/FlinkOptions.java    | 20 +++------
 .../hudi/configuration/HadoopConfigurations.java   | 48 ++++++++++++++++++++++
 .../hudi/schema/FilebasedSchemaProvider.java       |  6 ++-
 .../hudi/sink/bootstrap/BootstrapOperator.java     |  3 +-
 .../hudi/sink/bulk/BulkInsertWriteFunction.java    |  2 +-
 .../org/apache/hudi/sink/meta/CkpMetadata.java     | 12 +++---
 .../sink/partitioner/BucketAssignFunction.java     |  3 +-
 .../apache/hudi/sink/utils/HiveSyncContext.java    |  4 +-
 .../java/org/apache/hudi/source/FileIndex.java     |  3 +-
 .../hudi/source/StreamReadMonitoringFunction.java  |  3 +-
 .../org/apache/hudi/table/HoodieTableSource.java   |  5 ++-
 .../apache/hudi/table/catalog/HoodieCatalog.java   |  3 +-
 .../org/apache/hudi/table/format/FormatUtils.java  | 12 ------
 .../table/format/mor/MergeOnReadInputFormat.java   |  6 +--
 .../java/org/apache/hudi/util/FlinkTables.java     |  4 +-
 .../java/org/apache/hudi/util/StreamerUtil.java    | 25 ++++-------
 .../apache/hudi/util/ViewStorageProperties.java    | 11 +++--
 .../sink/TestStreamWriteOperatorCoordinator.java   |  5 ++-
 .../org/apache/hudi/sink/meta/TestCkpMetadata.java |  3 +-
 .../hudi/sink/partitioner/TestBucketAssigner.java  |  3 +-
 .../org/apache/hudi/sink/utils/TestWriteBase.java  |  3 +-
 .../apache/hudi/source/TestStreamReadOperator.java |  3 +-
 .../apache/hudi/table/format/TestInputFormat.java  |  3 +-
 .../org/apache/hudi/utils/TestStreamerUtil.java    |  2 +-
 .../test/java/org/apache/hudi/utils/TestUtils.java | 11 ++---
 .../hudi/utils/TestViewStorageProperties.java      | 10 +++--
 26 files changed, 126 insertions(+), 87 deletions(-)
 create mode 100644 hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/HadoopConfigurations.java