This commit is contained in:
Xin Zhang 2024-09-03 14:44:35 -04:00
Родитель 80c8258c9c
Коммит 4b85d3aef3
1 изменённых файлов: 3 добавлений и 3 удалений

Просмотреть файл

@ -184,10 +184,10 @@ public class MongoDbReactiveStreamsClient extends DB {
// Set is inserts are done as upserts. Defaults to false.
useUpsert = this.getBooleanProperty("mongodb.upsert", DEFAULT_USE_UPSERT);
// Just use the standard connection format URL
// http://docs.mongodb.org/manual/reference/connection-string/
// check http://docs.mongodb.org/manual/reference/connection-string/
// to configure the client.
String url = this.getStringProperty("mongodb.url", "mongodb://localhost:27017/ycsb?w=1");
url = OptionsSupport.updateUrl(url, getProperties());
ConnectionString connectionString = new ConnectionString(url);
try {
@ -213,7 +213,7 @@ public class MongoDbReactiveStreamsClient extends DB {
LOGGER.error("Could not initialize MongoDB connection pool for Loader: "
+ e1.toString());
e1.printStackTrace();
return;
System.exit(1);
}
}
}