[HUDI-5007] Prevent Hudi from reading the entire timeline's when perf…

…orming a LATEST streaming read (#6920)
apache · Dec 13, 2022 · 2f419a5 · 2f419a5
1 parent 6f2a1e9
commit 2f419a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nk-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java b/...nk-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java
@@ -465,7 +465,7 @@ public List<HoodieInstant> filterInstantsWithRange(
 
     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));
       }