diff --git a/src/main/java/net/spy/memcached/MemcachedClient.java b/src/main/java/net/spy/memcached/MemcachedClient.java
index 2ae7bdd4..fbba0357 100644
--- a/src/main/java/net/spy/memcached/MemcachedClient.java
+++ b/src/main/java/net/spy/memcached/MemcachedClient.java
@@ -2772,7 +2772,7 @@ public void complete() {
   @Override
   public OperationFuture<Boolean> flush(final int delay) {
     final AtomicReference<Boolean> flushResult =
-        new AtomicReference<Boolean>(null);
+        new AtomicReference<Boolean>(true);
     final ConcurrentLinkedQueue<Operation> ops =
         new ConcurrentLinkedQueue<Operation>();
     CountDownLatch blatch = broadcastOp(new BroadcastOpFactory() {
@@ -2782,7 +2782,9 @@ public Operation newOp(final MemcachedNode n,
         Operation op = opFact.flush(delay, new OperationCallback() {
           @Override
           public void receivedStatus(OperationStatus s) {
-            flushResult.set(s.isSuccess());
+            if (!s.isSuccess()) {
+              flushResult.set(false);
+            }
           }
 
           @Override