(shardingsphere) branch master updated: Only delete versions smaller than the current active version (#34182)

[duanzhengqiang]

This is an automated email from the ASF dual-hosted git repository.

duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 5d34661af58 Only delete versions smaller than the current active 
version (#34182)
5d34661af58 is described below

commit 5d34661af580836662cec52f16015e862f65827f
Author: Haoran Meng <menghaora...@gmail.com>
AuthorDate: Fri Dec 27 17:30:09 2024 +0800

    Only delete versions smaller than the current active version (#34182)
---
 .../metadata/persist/service/version/MetaDataVersionPersistService.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/version/MetaDataVersionPersistService.java
 
b/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/version/MetaDataVersionPersistService.java
index 7e7820493e4..ea7a36d1800 100644
--- 
a/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/version/MetaDataVersionPersistService.java
+++ 
b/kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/version/MetaDataVersionPersistService.java
@@ -43,7 +43,7 @@ public final class MetaDataVersionPersistService implements 
MetaDataVersionBased
             }
             repository.persist(each.getActiveVersionNodePath(), 
each.getNextActiveVersion());
             getVersions(each.getVersionsPath()).stream()
-                    .filter(version -> 
!version.equals(each.getNextActiveVersion()))
+                    .filter(version -> Integer.parseInt(version) < 
Integer.parseInt(each.getNextActiveVersion()))
                     .forEach(version -> 
repository.delete(each.getVersionsNodePath(version)));
         }
     }