Skip to content

Commit 995d35c

Browse files
[BugFix] Clear mv's version map if restore job failed (backport #62634) (#62645)
Signed-off-by: shuming.li <ming.moriarty@gmail.com> Co-authored-by: shuming.li <ming.moriarty@gmail.com>
1 parent 46fa990 commit 995d35c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

fe/fe-core/src/main/java/com/starrocks/backup/RestoreJob.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1578,6 +1578,8 @@ private Status allTabletCommitted(boolean isReplay) {
15781578
MaterializedView mv = (MaterializedView) olapTable;
15791579
mv.setInactiveAndReason(MaterializedViewExceptions
15801580
.inactiveReasonForMetadataTableRestoreCorrupted(mv.getName()));
1581+
// clear version map so can be refreshed later
1582+
mv.getRefreshScheme().getAsyncRefreshContext().clearVisibleVersionMap();
15811583
// drop all partitions
15821584
Set<String> partitionNames = mv.getPartitionNames();
15831585
for (String partitionName : partitionNames) {

0 commit comments

Comments
 (0)