diff --git a/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/EntryLogTest.java b/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/EntryLogTest.java index f402a949244..c60a997a26a 100644 --- a/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/EntryLogTest.java +++ b/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/EntryLogTest.java @@ -80,6 +80,8 @@ public void testCorruptEntryLog() throws Exception { int gcWaitTime = 1000; ServerConfiguration conf = TestBKConfiguration.newServerConfiguration(); + conf.setJournalDirName(tmpDir.toString()); + conf.setGcWaitTime(gcWaitTime); conf.setLedgerDirNames(new String[] {tmpDir.toString()}); Bookie bookie = new Bookie(conf); @@ -120,6 +122,7 @@ public void testMissingLogId() throws Exception { Bookie.checkDirectoryStructure(curDir); ServerConfiguration conf = TestBKConfiguration.newServerConfiguration(); + conf.setJournalDirName(tmpDir.toString()); conf.setLedgerDirNames(new String[] {tmpDir.toString()}); Bookie bookie = new Bookie(conf); // create some entries @@ -206,6 +209,7 @@ public void testAddEntryFailureOnDiskFull() throws Exception { File ledgerDir1 = createTempDir("bkTest", ".dir"); File ledgerDir2 = createTempDir("bkTest", ".dir"); ServerConfiguration conf = TestBKConfiguration.newServerConfiguration(); + conf.setJournalDirName(ledgerDir1.toString()); conf.setLedgerDirNames(new String[] { ledgerDir1.getAbsolutePath(), ledgerDir2.getAbsolutePath() }); Bookie bookie = new Bookie(conf); @@ -240,6 +244,8 @@ public void testRecoverFromLedgersMap() throws Exception { int gcWaitTime = 1000; ServerConfiguration conf = TestBKConfiguration.newServerConfiguration(); + conf.setJournalDirName(tmpDir.toString()); + conf.setGcWaitTime(gcWaitTime); conf.setLedgerDirNames(new String[] {tmpDir.toString()}); Bookie bookie = new Bookie(conf); @@ -276,6 +282,7 @@ public void testRecoverFromLedgersMapOnV0EntryLog() throws Exception { ServerConfiguration conf = TestBKConfiguration.newServerConfiguration(); conf.setGcWaitTime(gcWaitTime); conf.setLedgerDirNames(new String[] { tmpDir.toString() }); + conf.setJournalDirName(tmpDir.toString()); Bookie bookie = new Bookie(conf); // create some entries diff --git a/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/LedgerCacheTest.java b/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/LedgerCacheTest.java index 53083af886b..2fe5e75db99 100644 --- a/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/LedgerCacheTest.java +++ b/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/LedgerCacheTest.java @@ -272,6 +272,7 @@ public void testLedgerCacheFlushFailureOnDiskFull() throws Exception { File ledgerDir2 = createTempDir("bkTest", ".dir"); ServerConfiguration conf = TestBKConfiguration.newServerConfiguration(); conf.setLedgerDirNames(new String[] { ledgerDir1.getAbsolutePath(), ledgerDir2.getAbsolutePath() }); + conf.setJournalDirName(ledgerDir1.toString()); Bookie bookie = new Bookie(conf); InterleavedLedgerStorage ledgerStorage = ((InterleavedLedgerStorage) bookie.ledgerStorage); @@ -517,6 +518,7 @@ public void testEntryMemTableFlushFailure() throws Exception { ServerConfiguration conf = TestBKConfiguration.newServerConfiguration(); conf.setGcWaitTime(gcWaitTime); conf.setLedgerDirNames(new String[] { tmpDir.toString() }); + conf.setJournalDirName(tmpDir.toString()); conf.setLedgerStorageClass(FlushTestSortedLedgerStorage.class.getName()); Bookie bookie = new Bookie(conf);