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 2021/10/18 02:46:44 UTC
[hudi] branch master updated (9aa7cfb -> 2eda3de)
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 9aa7cfb [MINOR] fix typo,'seprarated' corrected to 'separated' (#3789)
add 2eda3de [HUDI-2562] Embedded timeline server on JobManager (#3812)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/io/HoodieAppendHandle.java | 4 +-
.../apache/hudi/client/HoodieFlinkWriteClient.java | 38 ------
.../FlinkHoodieBackedTableMetadataWriter.java | 2 +-
.../org/apache/hudi/table/HoodieFlinkTable.java | 18 ++-
.../index/bloom/TestFlinkHoodieBloomIndex.java | 2 +-
.../table/timeline/HoodieActiveTimeline.java | 5 +
.../org/apache/hudi/sink/StreamWriteFunction.java | 3 +-
.../hudi/sink/StreamWriteOperatorCoordinator.java | 57 ++++++---
.../hudi/sink/append/AppendWriteFunction.java | 9 --
.../hudi/sink/bootstrap/BootstrapOperator.java | 16 +--
.../hudi/sink/bulk/BulkInsertWriteFunction.java | 25 ++--
.../sink/common/AbstractStreamWriteFunction.java | 53 ++++----
.../hudi/sink/compact/HoodieFlinkCompactor.java | 3 +-
.../sink/partitioner/BucketAssignFunction.java | 2 +-
.../hudi/sink/partitioner/BucketAssigner.java | 48 +++++--
.../partitioner/profile/DeltaWriteProfile.java | 7 +-
.../sink/partitioner/profile/WriteProfile.java | 28 ++--
.../java/org/apache/hudi/sink/utils/TimeWait.java | 48 +++++--
.../org/apache/hudi/table/HoodieTableSink.java | 6 +-
.../java/org/apache/hudi/util/StreamerUtil.java | 74 +++++++++--
.../apache/hudi/util/ViewStorageProperties.java | 82 ++++++++++++
.../sink/TestStreamWriteOperatorCoordinator.java | 10 +-
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 141 ++++++++++-----------
.../org/apache/hudi/sink/TestWriteMergeOnRead.java | 12 +-
.../hudi/sink/TestWriteMergeOnReadWithCompact.java | 6 +
.../sink/compact/ITTestHoodieFlinkCompactor.java | 11 +-
.../hudi/sink/partitioner/TestBucketAssigner.java | 25 ++--
.../hudi/sink/utils/InsertFunctionWrapper.java | 6 -
.../sink/utils/StreamWriteFunctionWrapper.java | 6 -
.../source/TestStreamReadMonitoringFunction.java | 6 +-
.../apache/hudi/table/HoodieDataSourceITCase.java | 36 +++---
.../org/apache/hudi/utils/TestCompactionUtil.java | 2 +-
.../test/java/org/apache/hudi/utils/TestUtils.java | 26 +++-
.../hudi/utils/TestViewStorageProperties.java | 57 +++++++++
34 files changed, 540 insertions(+), 334 deletions(-)
create mode 100644 hudi-flink/src/main/java/org/apache/hudi/util/ViewStorageProperties.java
create mode 100644 hudi-flink/src/test/java/org/apache/hudi/utils/TestViewStorageProperties.java