[BugFix] Clear mv's version map if restore job failed (backport #62634) (#62644)

Signed-off-by: shuming.li <ming.moriarty@gmail.com>
Co-authored-by: shuming.li <ming.moriarty@gmail.com>
This commit is contained in:
mergify[bot] 2025-09-02 18:46:22 +08:00 committed by GitHub
parent ebf06bbe4e
commit 3c9d5cb89c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 0 deletions

View File

@ -1682,6 +1682,8 @@ public class RestoreJob extends AbstractJob {
MaterializedView mv = (MaterializedView) olapTable;
mv.setInactiveAndReason(MaterializedViewExceptions
.inactiveReasonForMetadataTableRestoreCorrupted(mv.getName()));
// clear version map so can be refreshed later
mv.getRefreshScheme().getAsyncRefreshContext().clearVisibleVersionMap();
// drop all partitions
Set<String> partitionNames = mv.getPartitionNames();
for (String partitionName : partitionNames) {