This is an automated email from the ASF dual-hosted git repository. satish pushed a commit to branch release-0.12.2 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 2f419a503ab0009cc96467fb8d6150d168ff15cd Author: voonhous <voonho...@gmail.com> AuthorDate: Tue Nov 29 11:53:31 2022 +0800 [HUDI-5007] Prevent Hudi from reading the entire timeline's when performing a LATEST streaming read (#6920) --- .../src/main/java/org/apache/hudi/source/IncrementalInputSplits.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java index 7e0eda46cec..0c2be61745f 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java @@ -465,7 +465,7 @@ public class IncrementalInputSplits implements Serializable { if (OptionsResolver.hasNoSpecificReadCommits(this.conf)) { // by default read from the latest commit - List<HoodieInstant> instants = completedTimeline.getInstants().collect(Collectors.toList()); + List<HoodieInstant> instants = completedTimeline.getInstants(); if (instants.size() > 1) { return Collections.singletonList(instants.get(instants.size() - 1)); }