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%)