Fix policy update issue

jd-opensource · Dec 27, 2024 · b73d0a1 · b73d0a1
1 parent 5dc497f
commit b73d0a1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...ve-governance-api/src/main/java/com/jd/live/agent/governance/policy/GovernancePolicy.java b/...ve-governance-api/src/main/java/com/jd/live/agent/governance/policy/GovernancePolicy.java
@@ -315,7 +315,7 @@ public List<Service> onUpdate(List<Service> updates, Set<String> deletes, Policy
                             result.add(old);
                         }
                     }
-                } else if (old.getVersion() < update.getVersion()) {
+                } else if (old.getVersion() != update.getVersion()) {
                     // Update
                     ServiceOp.onUpdate(old, update, merger, owner);
                     result.add(old);

diff --git a/...nance-api/src/main/java/com/jd/live/agent/governance/policy/listener/ServiceListener.java b/...nance-api/src/main/java/com/jd/live/agent/governance/policy/listener/ServiceListener.java
@@ -68,7 +68,7 @@ protected void updateItems(GovernancePolicy policy, List<Service> items, ConfigE
                 loadedServices.add(item.getName());
                 newVersions.put(item.getName(), item.getVersion());
                 long oldVersion = oldVersions.getOrDefault(item.getName(), -1L);
-                if (item.getVersion() > oldVersion) {
+                if (item.getVersion() != oldVersion) {
                     updates.add(item);
                 }
             }