[hudi] 09/22: [HUDI-5007] Prevent Hudi from reading the entire timeline's when performing a LATEST streaming read (#6920)

[satish]

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));
       }