This is an automated email from the ASF dual-hosted git repository. sivabalan pushed a commit to branch release-0.12.2-shadow in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 1b4b40e44a176cefcb692c85a2242cc539348c17 Author: Shiyan Xu <[email protected]> AuthorDate: Wed Dec 7 14:42:57 2022 +0800 [HUDI-5334] Fix checkpoint reading for structured streaming (#7389) --- hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java b/hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java index 6baacf1ec88..ce94c92fd45 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java @@ -151,7 +151,7 @@ public class CommitUtils { * @return An optional commit metadata with latest checkpoint. */ public static Option<HoodieCommitMetadata> getLatestCommitMetadataWithValidCheckpointInfo(HoodieTimeline timeline, String checkpointKey) { - return (Option<HoodieCommitMetadata>) timeline.getReverseOrderedInstants().map(instant -> { + return (Option<HoodieCommitMetadata>) timeline.filterCompletedInstants().getReverseOrderedInstants().map(instant -> { try { HoodieCommitMetadata commitMetadata = HoodieCommitMetadata .fromBytes(timeline.getInstantDetails(instant).get(), HoodieCommitMetadata.class);
