This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 5e518746492 [HUDI-6304] Handle cases when inflight files are removed
and job failed leaving pending rollback files (#8849)
add fcdab57ba21 [HUDI-6312] Guard incremental query for multi-writer
scenario (#8876)
No new revisions were added by this update.
Summary of changes:
.../hudi/common/config/HoodieCommonConfig.java | 26 ++++++++---
.../hudi/common/table/timeline/TimelineUtils.java | 52 +++++++++++++++++++++-
.../org/apache/hudi/common/util/ConfigUtils.java | 5 +++
.../hudi/common/table/TestTimelineUtils.java | 43 ++++++++++++++++++
.../apache/hudi/configuration/OptionsResolver.java | 7 ++-
.../apache/hudi/source/IncrementalInputSplits.java | 8 ++--
.../hudi/source/TestIncrementalInputSplits.java | 2 +-
.../hudi/hadoop/utils/HoodieInputFormatUtils.java | 12 ++++-
.../scala/org/apache/hudi/DataSourceOptions.scala | 20 +++++----
.../org/apache/hudi/IncrementalRelation.scala | 24 ++++++----
.../hudi/MergeOnReadIncrementalRelation.scala | 26 ++++++-----
.../sql/hudi/streaming/HoodieStreamSource.scala | 37 +++++++++------
.../TestIncrementalReadByStateTransitionTime.scala | 7 +--
...TestStreamSourceReadByStateTransitionTime.scala | 8 ++--
.../hudi/functional/TestStreamingSource.scala | 16 ++++---
.../sources/GcsEventsHoodieIncrSource.java | 15 ++++---
.../hudi/utilities/sources/HoodieIncrSource.java | 33 +++++++++-----
.../sources/S3EventsHoodieIncrSource.java | 30 ++++++++-----
.../sources/helpers/IncrSourceHelper.java | 51 +++++++++++----------
.../utilities/sources/helpers/gcs/QueryInfo.java | 16 ++++---
.../utilities/sources/TestHoodieIncrSource.java | 6 +--
21 files changed, 316 insertions(+), 128 deletions(-)
