[hudi] 02/10: [HUDI-5334] Fix checkpoint reading for structured streaming (#7389)

[si...@apache.org]

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 <27...@users.noreply.github.com>
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);