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 cff384d [HUDI-2552] Fixing some test failures to unblock broken CI
master (#3793)
add abf3e3f [HUDI-2548] Flink streaming reader misses the rolling over
file handles (#3787)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 2 +-
.../hudi/common/model/HoodieCommitMetadata.java | 59 ++++++++++++++++-
.../table/timeline/HoodieArchivedTimeline.java | 13 ++--
.../apache/hudi/configuration/FlinkOptions.java | 4 +-
.../org/apache/hudi/sink/StreamWriteFunction.java | 5 +-
.../hudi/sink/StreamWriteOperatorCoordinator.java | 8 ++-
.../sink/partitioner/profile/WriteProfile.java | 2 +-
.../sink/partitioner/profile/WriteProfiles.java | 77 ++++++++++++----------
.../apache/hudi/source/IncrementalInputSplits.java | 23 ++-----
.../hudi/source/StreamReadMonitoringFunction.java | 2 +-
.../apache/hudi/streamer/FlinkStreamerConfig.java | 4 +-
.../java/org/apache/hudi/util/StreamerUtil.java | 12 +++-
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 13 ++--
.../apache/hudi/table/HoodieDataSourceITCase.java | 38 +++++++++--
.../hudi/hadoop/utils/HoodieInputFormatUtils.java | 72 ++++++++++----------
.../hudi/MergeOnReadIncrementalRelation.scala | 17 ++---
16 files changed, 225 insertions(+), 126 deletions(-)
