Remove uncessary chagne

apache · Jan 10, 2025 · 8fe93c7 · 8fe93c7
1 parent 39ca7fa
commit 8fe93c7
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...e/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadIncrementalRelationV2.scala b/...e/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadIncrementalRelationV2.scala
@@ -205,7 +205,15 @@ trait HoodieIncrementalRelationV2Trait extends HoodieBaseRelation {
       .analyze()
 
   protected lazy val includedCommits: immutable.Seq[HoodieInstant] = queryContext.getInstants.asScala.toList
-  protected lazy val commitsMetadata = includedCommits.map(getCommitMetadata(_, super.timeline)).asJava
+
+  protected lazy val commitsMetadata = includedCommits.map(
+    i => {
+      if (queryContext.getArchivedInstants.contains(i)) {
+        getCommitMetadata(i, queryContext.getArchivedTimeline)
+      } else {
+        getCommitMetadata(i, queryContext.getActiveTimeline)
+      }
+    }).asJava
 
   protected lazy val affectedFilesInCommits: java.util.List[StoragePathInfo] = {
     listAffectedFilesForCommits(conf, metaClient.getBasePath, commitsMetadata)