This is an automated email from the ASF dual-hosted git repository.
vinoyang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 3e4fa17 [HUDI-1835] Fixing kafka native config param for auto offset
reset (#2864)
add d047e91 [HUDI-1837] Add optional instant range to log record scanner
for log (#2870)
No new revisions were added by this update.
Summary of changes:
...SparkExecuteClusteringCommitActionExecutor.java | 17 +++--
.../table/log/AbstractHoodieLogRecordScanner.java | 18 ++++-
.../table/log/HoodieMergedLogRecordScanner.java | 52 ++++++++------
.../table/log/HoodieUnMergedLogRecordScanner.java | 8 +--
.../hudi/common/table/log}/InstantRange.java | 4 +-
.../hudi/metadata/HoodieBackedTableMetadata.java | 12 +++-
.../HoodieMetadataMergedLogRecordScanner.java | 79 +++++++++++++++++++++-
.../apache/hudi/configuration/FlinkOptions.java | 6 ++
.../hudi/source/StreamReadMonitoringFunction.java | 2 +-
.../org/apache/hudi/table/format/FormatUtils.java | 1 +
.../table/format/mor/MergeOnReadInputFormat.java | 12 ----
.../table/format/mor/MergeOnReadInputSplit.java | 1 +
.../java/org/apache/hudi/util/StreamerUtil.java | 1 +
13 files changed, 159 insertions(+), 54 deletions(-)
rename {hudi-flink/src/main/java/org/apache/hudi/table/format/mor =>
hudi-common/src/main/java/org/apache/hudi/common/table/log}/InstantRange.java
(97%)
