diff --git a/fe/fe-core/src/test/java/com/starrocks/journal/bdbje/BDBJEJournalTest.java b/fe/fe-core/src/test/java/com/starrocks/journal/bdbje/BDBJEJournalTest.java index 3c1a77665d98c..70229df739fef 100644 --- a/fe/fe-core/src/test/java/com/starrocks/journal/bdbje/BDBJEJournalTest.java +++ b/fe/fe-core/src/test/java/com/starrocks/journal/bdbje/BDBJEJournalTest.java @@ -771,25 +771,50 @@ public void write(DataOutput out) throws IOException { writable.write(buffer); BDBEnvironment environment = initBDBEnv("testJournalWithPrefix"); - BDBJEJournal journal = new BDBJEJournal(environment, "aaa_"); - Assert.assertEquals("aaa_", journal.getPrefix()); - journal.open(); - journal.batchWriteBegin(); - journal.batchWriteAppend(1, buffer); - journal.batchWriteAppend(2, buffer); - journal.batchWriteCommit(); - - journal.rollJournal(3); - journal.open(); - journal.batchWriteBegin(); - journal.batchWriteAppend(3, buffer); - journal.batchWriteAppend(4, buffer); - journal.batchWriteCommit(); + // test journal with prefix works fine + { + BDBJEJournal journalWithPrefix = new BDBJEJournal(environment, "aaa_"); + Assert.assertEquals("aaa_", journalWithPrefix.getPrefix()); + journalWithPrefix.open(); + journalWithPrefix.batchWriteBegin(); + journalWithPrefix.batchWriteAppend(1, buffer); + journalWithPrefix.batchWriteAppend(2, buffer); + journalWithPrefix.batchWriteCommit(); + + journalWithPrefix.rollJournal(3); + journalWithPrefix.open(); + journalWithPrefix.batchWriteBegin(); + journalWithPrefix.batchWriteAppend(3, buffer); + journalWithPrefix.batchWriteAppend(4, buffer); + journalWithPrefix.batchWriteCommit(); + + List l = journalWithPrefix.getDatabaseNames(); + Assert.assertEquals(2, l.size()); + Assert.assertEquals((Long) 1L, l.get(0)); + Assert.assertEquals((Long) 3L, l.get(1)); + } - List l = journal.getDatabaseNames(); - Assert.assertEquals(2, l.size()); - Assert.assertEquals((Long) 1L, l.get(0)); - Assert.assertEquals((Long) 3L, l.get(1)); + // test journal without prefix works fine at the same time + { + BDBJEJournal journalWithoutPrefix = new BDBJEJournal(environment); + journalWithoutPrefix.open(); + journalWithoutPrefix.batchWriteBegin(); + journalWithoutPrefix.batchWriteAppend(1, buffer); + journalWithoutPrefix.batchWriteAppend(2, buffer); + journalWithoutPrefix.batchWriteCommit(); + + journalWithoutPrefix.rollJournal(3); + journalWithoutPrefix.open(); + journalWithoutPrefix.batchWriteBegin(); + journalWithoutPrefix.batchWriteAppend(3, buffer); + journalWithoutPrefix.batchWriteAppend(4, buffer); + journalWithoutPrefix.batchWriteCommit(); + + List l = journalWithoutPrefix.getDatabaseNames(); + Assert.assertEquals(2, l.size()); + Assert.assertEquals((Long) 1L, l.get(0)); + Assert.assertEquals((Long) 3L, l.get(1)); + } } }