[HUDI-5334] Fix checkpoint reading for structured streaming (#7389)

apache · Dec 7, 2022 · 4d9035e · 4d9035e
1 parent 6629bf7
commit 4d9035e
Showing 1 changed file with 1 addition and 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
@@ -151,7 +151,7 @@ public static HashMap<String, String> getFileIdWithoutSuffixAndRelativePaths(Map
    * @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);