diff --git a/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java b/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java index 06c301bec9c..0c0690da5ce 100644 --- a/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java +++ b/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java @@ -64,7 +64,7 @@ public void run0() { this.waitForRunning(WATCH_INTERVAL); for (Map.Entry entry : currentHash.entrySet()) { String newHash = md5Digest(entry.getKey()); - if (!newHash.equals(currentHash.get(entry.getKey()))) { + if (!newHash.equals(entry.getValue())) { entry.setValue(newHash); listener.onChanged(entry.getKey()); }