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 464027e [HUDI-3239] Convert `BaseHoodieTableFileIndex` to Java (#4669)
add b3b4423 [HUDI-3389] Bump flink version to 1.14.3 (#4776)
No new revisions were added by this update.
Summary of changes:
hudi-client/hudi-flink-client/pom.xml | 4 ++--
hudi-flink/pom.xml | 8 ++++----
.../hudi/sink/StreamWriteOperatorCoordinator.java | 10 ++++------
.../RowDataToHoodieFunctionWithRateLimit.java | 2 +-
.../java/org/apache/hudi/sink/utils/Pipelines.java | 9 ++++++++-
.../org/apache/hudi/source/StreamReadOperator.java | 16 ++++++++--------
.../org/apache/hudi/sink/StreamWriteITCase.java | 4 ++--
.../apache/hudi/sink/utils/CollectorOutput.java | 6 ++++++
.../hudi/sink/utils/CompactFunctionWrapper.java | 6 ++++++
.../sink/utils/MockStateInitializationContext.java | 7 +++++++
.../sink/utils/MockStreamingRuntimeContext.java | 6 +++---
.../apache/hudi/table/HoodieDataSourceITCase.java | 22 ++++++++++++++++++++--
pom.xml | 2 +-
13 files changed, 72 insertions(+), 30 deletions(-)
