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 c74e8e6c5b0 [HUDI-9412] Support displaying metrics of
Update/Delete/MergeIntoHoodieTableCommand in Spark Web UI (#13304)
add e34a7ab8152 [HUDI-9381] Async instant time generation of Flink writers
(#13285)
No new revisions were added by this update.
Summary of changes:
.../client/embedded/EmbeddedTimelineService.java | 24 +-
.../lock/FileSystemBasedLockProvider.java | 2 +
.../org/apache/hudi/config/HoodieWriteConfig.java | 25 --
.../common/table/timeline/TimeGeneratorBase.java | 8 +-
.../common/table/timeline/dto/InstantStateDTO.java | 68 -----
.../org/apache/hudi/sink/StreamWriteFunction.java | 4 +-
.../hudi/sink/StreamWriteOperatorCoordinator.java | 306 ++++++++++-----------
.../hudi/sink/append/AppendWriteFunction.java | 18 +-
.../hudi/sink/bootstrap/BootstrapOperator.java | 8 +-
.../hudi/sink/bulk/BulkInsertWriteFunction.java | 58 +---
.../sink/common/AbstractStreamWriteFunction.java | 170 ++++++------
.../hudi/sink/common/AbstractWriteFunction.java | 7 +
.../hudi/sink/common/AbstractWriteOperator.java | 6 +
.../hudi/sink/common/WriteOperatorFactory.java | 3 +
.../org/apache/hudi/sink/event/Correspondent.java | 111 ++++++++
.../apache/hudi/sink/event/WriteMetadataEvent.java | 25 +-
.../java/org/apache/hudi/sink/meta/CkpMessage.java | 113 --------
.../org/apache/hudi/sink/meta/CkpMetadata.java | 252 -----------------
.../apache/hudi/sink/meta/CkpMetadataFactory.java | 43 ---
.../hudi/sink/meta/TimelineBasedCkpMetadata.java | 112 --------
.../hudi/sink/utils/CoordinationResponseSeDe.java | 165 +++++++++++
.../org/apache/hudi/sink/utils/EventBuffers.java | 120 ++++++++
.../utils/ExplicitClassloaderThreadFactory.java | 63 +++++
.../apache/hudi/sink/utils/NonThrownExecutor.java | 13 +-
.../java/org/apache/hudi/sink/utils/Pipelines.java | 2 +-
.../org/apache/hudi/util/FlinkWriteClients.java | 4 +
.../sink/TestStreamWriteOperatorCoordinator.java | 230 ++++++++--------
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 71 +++--
.../hudi/sink/TestWriteMergeOnReadWithCompact.java | 65 ++---
.../TestWriteWithTimelineBasedCkpMetadata.java | 63 -----
.../org/apache/hudi/sink/meta/TestCkpMetadata.java | 120 --------
.../sink/meta/TestTimelineBasedCkpMetadata.java | 117 --------
.../utils/BucketStreamWriteFunctionWrapper.java | 13 +-
.../hudi/sink/utils/BulkInsertFunctionWrapper.java | 8 +-
.../hudi/sink/utils/InsertFunctionWrapper.java | 8 +-
.../hudi/sink/utils/MockCoordinatorExecutor.java | 2 +-
.../apache/hudi/sink/utils/MockCorrespondent.java} | 34 +--
.../sink/utils/StreamWriteFunctionWrapper.java | 12 +-
.../hudi/sink/utils/TestFunctionWrapper.java | 14 +-
.../org/apache/hudi/sink/utils/TestWriteBase.java | 151 +++++-----
.../org/apache/hudi/common/util/RetryHelper.java | 4 +-
.../hudi/timeline/service/RequestHandler.java | 29 --
.../hudi/timeline/service/TimelineService.java | 22 --
.../service/handlers/InstantStateHandler.java | 132 ---------
44 files changed, 1074 insertions(+), 1751 deletions(-)
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/InstantStateDTO.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/event/Correspondent.java
delete mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java
delete mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java
delete mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadataFactory.java
delete mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/TimelineBasedCkpMetadata.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/CoordinationResponseSeDe.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/EventBuffers.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/ExplicitClassloaderThreadFactory.java
delete mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteWithTimelineBasedCkpMetadata.java
delete mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/meta/TestCkpMetadata.java
delete mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/meta/TestTimelineBasedCkpMetadata.java
copy
hudi-flink-datasource/hudi-flink/src/{main/java/org/apache/hudi/util/FlinkStateBackendConverter.java
=> test/java/org/apache/hudi/sink/utils/MockCorrespondent.java} (51%)
delete mode 100644
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/InstantStateHandler.java
