[HUDI-4807] Use base table instant for metadata initialization (apach…

…e#6629)
TengHuo · Oct 7, 2022 · 769d37f · 769d37f
1 parent 30f6988
commit 769d37f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-common/src/main/java/org/apache/hudi/table/action/index/ScheduleIndexActionExecutor.java b/...-common/src/main/java/org/apache/hudi/table/action/index/ScheduleIndexActionExecutor.java
@@ -107,7 +107,7 @@ public Option<HoodieIndexPlan> execute() {
             .orElseThrow(() -> new HoodieIndexException(String.format("Could not get metadata writer to initialize filegroups for indexing for instant: %s", instantTime)));
         if (!finalPartitionsToIndex.get(0).getPartitionPath().equals(MetadataPartitionType.FILES.getPartitionPath())) {
           // initialize metadata partition only if not for FILES partition.
-          metadataWriter.initializeMetadataPartitions(table.getMetaClient(), finalPartitionsToIndex, indexInstant.getTimestamp());
+          metadataWriter.initializeMetadataPartitions(table.getMetaClient(), finalPartitionsToIndex, indexUptoInstant.get().getTimestamp());
         }
 
         // for each partitionToIndex add that time to the plan