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