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 d83fd43eca6077aeb1c21a1ab456744059c38a37..9c4a8da829de04f8e855d37601e1db29ce0b4b0b 100644 --- a/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java +++ b/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java @@ -124,7 +124,7 @@ public class AsyncMongoDbClient extends DB { final Properties props = getProperties(); final String maxConnections = props.getProperty( - "mongodb.maxconnections", "10"); + "mongodb.maxconnections", "100"); final int connections = Integer.parseInt(maxConnections); synchronized (AsyncMongoDbClient.class) { diff --git a/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java b/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java index 61fca0c07ba2a896076beeba0ba36d10b543901c..87005109bdd23007f4871151fff1fa44eb49c349 100644 --- a/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java +++ b/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java @@ -26,7 +26,6 @@ import com.mongodb.DBObject; import com.mongodb.MongoClient; import com.mongodb.MongoClientOptions; import com.mongodb.WriteConcern; -import com.mongodb.WriteResult; import com.yahoo.ycsb.ByteArrayByteIterator; import com.yahoo.ycsb.ByteIterator; import com.yahoo.ycsb.DB; @@ -94,7 +93,7 @@ public class MongoDbClient extends DB { // Set connectionpool to size of ycsb thread pool final String maxConnections = props.getProperty( - "mongodb.maxconnections", "10"); + "mongodb.maxconnections", "100"); final String threadsAllowedToBlockForConnectionMultiplier = props .getProperty( "mongodb.threadsAllowedToBlockForConnectionMultiplier", @@ -193,7 +192,7 @@ public class MongoDbClient extends DB { db.requestStart(); DBCollection collection = db.getCollection(table); DBObject q = new BasicDBObject().append("_id", key); - WriteResult res = collection.remove(q, writeConcern); + collection.remove(q, writeConcern); return 0; } catch (Exception e) { @@ -235,7 +234,7 @@ public class MongoDbClient extends DB { for (Map.Entry<String, ByteIterator> entry : values.entrySet()) { r.put(entry.getKey(), entry.getValue().toArray()); } - WriteResult res = collection.insert(r, writeConcern); + collection.insert(r, writeConcern); return 0; } catch (Exception e) { @@ -339,8 +338,7 @@ public class MongoDbClient extends DB { } u.put("$set", fieldsToSet); - WriteResult res = collection.update(q, u, false, false, - writeConcern); + collection.update(q, u, false, false, writeConcern); return 0; } catch (Exception e) {