diff --git a/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java b/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java index 89eb7d250080530b309d3ed7861ab975b70162fa..8b7920810e36684e79f55fa33e3f109db3013f1e 100644 --- a/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java +++ b/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java @@ -462,7 +462,7 @@ public class AsyncMongoDbClient extends DB { } final long res = collection.update(query, update, false, false, writeConcern); - return res == 1 ? Status.OK : Status.NOT_FOUND; + return writeConcern == Durability.NONE || res == 1 ? Status.OK : Status.NOT_FOUND; } catch (final Exception e) { System.err.println(e.toString()); return Status.ERROR;