diff --git a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedValue.java b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedValue.java index 50e50edd0..e5e16927b 100644 --- a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedValue.java +++ b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedValue.java @@ -196,7 +196,7 @@ public boolean trySetValue(VersionedValue previous, byte[] newValue) thr private void updateValue(int version, byte[] bytes) { while (true) { VersionedValue current = currentValue.get(); - if (current.getVersion() >= version) { + if (current.getVersion() >= version && version != Integer.MIN_VALUE) { // A newer version was concurrently set. return; }