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 f5de6628b88 [HUDI-8920] [RFC-84] Optimize SerDe of stream records for
Flink write (excluding bulk insert and append mode) (#12796)
add 19432453799 [hudi-9041] Send commit ack event when reusing current
instant (#12849)
No new revisions were added by this update.
Summary of changes:
.../hudi/sink/StreamWriteOperatorCoordinator.java | 3 ++
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 24 +++++++++++++++
.../utils/BucketStreamWriteFunctionWrapper.java | 6 ++++
.../hudi/sink/utils/BulkInsertFunctionWrapper.java | 6 ++++
.../hudi/sink/utils/InsertFunctionWrapper.java | 15 ++++++++++
.../hudi/sink/utils/MockSubtaskGateway.java} | 35 +++++++++++++---------
.../sink/utils/StreamWriteFunctionWrapper.java | 6 ++++
.../hudi/sink/utils/TestFunctionWrapper.java | 15 +++++++++-
.../org/apache/hudi/sink/utils/TestWriteBase.java | 13 ++++++++
.../apache/hudi/adapter/ExecutionAttemptUtil.java} | 11 +++----
.../apache/hudi/adapter/ExecutionAttemptUtil.java} | 11 +++----
.../apache/hudi/adapter/ExecutionAttemptUtil.java} | 11 +++----
.../apache/hudi/adapter/ExecutionAttemptUtil.java} | 11 +++----
...odieCatalogs.java => ExecutionAttemptUtil.java} | 11 +++----
.../apache/hudi/adapter/ExecutionAttemptUtil.java} | 11 +++----
.../apache/hudi/adapter/ExecutionAttemptUtil.java} | 11 +++----
16 files changed, 150 insertions(+), 50 deletions(-)
copy
hudi-flink-datasource/{hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
=>
hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockSubtaskGateway.java}
(55%)
copy
hudi-flink-datasource/{hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java
=>
hudi-flink1.14.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java}
(77%)
copy
hudi-flink-datasource/{hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java
=>
hudi-flink1.15.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java}
(77%)
copy
hudi-flink-datasource/{hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java
=>
hudi-flink1.16.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java}
(77%)
copy
hudi-flink-datasource/{hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java
=>
hudi-flink1.17.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java}
(77%)
copy
hudi-flink-datasource/hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/{TestHoodieCatalogs.java
=> ExecutionAttemptUtil.java} (77%)
copy
hudi-flink-datasource/{hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java
=>
hudi-flink1.19.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java}
(77%)
copy
hudi-flink-datasource/{hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java
=>
hudi-flink1.20.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java}
(77%)
