This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 0d70df89fe [MINOR] Fix IncrementalInputSplits compilation failure
(#7319)
0d70df89fe is described below
commit 0d70df89fe6b7049d576e2b9bf75afb29c75c46d
Author: Alexander Trushev <[email protected]>
AuthorDate: Tue Nov 29 13:03:57 2022 +0700
[MINOR] Fix IncrementalInputSplits compilation failure (#7319)
---
.../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 d12feb4e73..0a10c77c22 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
@@ -492,7 +492,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));
}