diff --git a/mongodb/src/main/java/com/yahoo/ycsb/db/OptionsSupport.java b/mongodb/src/main/java/com/yahoo/ycsb/db/OptionsSupport.java index a1c0264eabe549d7a2e08bdbfffb6291d85912e4..4b1429609512627ae9b465ebeafcc41a40b87f3f 100644 --- a/mongodb/src/main/java/com/yahoo/ycsb/db/OptionsSupport.java +++ b/mongodb/src/main/java/com/yahoo/ycsb/db/OptionsSupport.java @@ -76,7 +76,8 @@ public final class OptionsSupport { result = addUrlOption(result, "w", "1"); } else if ("journaled".equals(writeConcernType)) { - result = addUrlOption(result, "j", "true"); + result = addUrlOption(result, "journal", "true"); // this is the documented option name + result = addUrlOption(result, "j", "true"); // but keep this until MongoDB Java driver supports "journal" option } else if ("replica_acknowledged".equals(writeConcernType)) { result = addUrlOption(result, "w", "2"); diff --git a/mongodb/src/test/java/com/yahoo/ycsb/db/OptionsSupportTest.java b/mongodb/src/test/java/com/yahoo/ycsb/db/OptionsSupportTest.java index adb9ec20ec6e410818993141f7899df1ade9d916..a1b9de650f9922e33c7a3b36bbf453bfaab03ee1 100644 --- a/mongodb/src/test/java/com/yahoo/ycsb/db/OptionsSupportTest.java +++ b/mongodb/src/test/java/com/yahoo/ycsb/db/OptionsSupportTest.java @@ -110,7 +110,7 @@ public class OptionsSupportTest { assertThat( updateUrl("mongodb://locahost:27017/?foo=bar", props("mongodb.writeConcern", "journaled")), - is("mongodb://locahost:27017/?foo=bar&j=true")); + is("mongodb://locahost:27017/?foo=bar&journal=true&j=true")); assertThat( updateUrl("mongodb://locahost:27017/?foo=bar", props("mongodb.writeConcern", "replica_acknowledged")),