@@ -60,6 +60,7 @@ public void init() throws IOException {
60
60
UUID .randomUUID ().toString ().replace ("-" , "" ).substring (0 , 8 )).toString ();
61
61
storeConfig = new TieredMessageStoreConfig ();
62
62
storeConfig .setStorePathRootDir (filePath );
63
+ storeConfig .setTieredStoreFilePath (filePath );
63
64
storeConfig .setTieredStoreIndexFileMaxHashSlotNum (5 );
64
65
storeConfig .setTieredStoreIndexFileMaxIndexNum (20 );
65
66
storeConfig .setTieredBackendServiceProvider ("org.apache.rocketmq.tieredstore.provider.posix.PosixFileSegment" );
@@ -73,6 +74,7 @@ public void shutdown() {
73
74
this .indexStoreFile .destroy ();
74
75
}
75
76
TieredStoreTestUtil .destroyMetadataStore ();
77
+ TieredStoreTestUtil .destroyTempDir (storeConfig .getStorePathRootDir ());
76
78
TieredStoreTestUtil .destroyTempDir (storeConfig .getTieredStoreFilePath ());
77
79
TieredStoreExecutor .shutdown ();
78
80
}
@@ -222,7 +224,7 @@ public void doCompactionTest() throws Exception {
222
224
223
225
ByteBuffer byteBuffer = indexStoreFile .doCompaction ();
224
226
TieredFileSegment fileSegment = new PosixFileSegment (
225
- storeConfig , FileSegmentType .INDEX , "store_index" , 0L );
227
+ storeConfig , FileSegmentType .INDEX , storeConfig . getTieredStoreFilePath () , 0L );
226
228
fileSegment .append (byteBuffer , timestamp );
227
229
fileSegment .commit ();
228
230
Assert .assertEquals (byteBuffer .limit (), fileSegment .getSize ());
@@ -255,7 +257,7 @@ public void queryAsyncFromSegmentFileTest() throws ExecutionException, Interrupt
255
257
256
258
ByteBuffer byteBuffer = indexStoreFile .doCompaction ();
257
259
TieredFileSegment fileSegment = new PosixFileSegment (
258
- storeConfig , FileSegmentType .INDEX , "store_index" , 0L );
260
+ storeConfig , FileSegmentType .INDEX , storeConfig . getTieredStoreFilePath () , 0L );
259
261
fileSegment .append (byteBuffer , timestamp );
260
262
fileSegment .commit ();
261
263
Assert .assertEquals (byteBuffer .limit (), fileSegment .getSize ());
0 commit comments