File tree Expand file tree Collapse file tree
broker/src/main/java/org/apache/rocketmq/broker/transaction
common/src/main/java/org/apache/rocketmq/common
store/src/main/java/org/apache/rocketmq/store/timer Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2424import java .io .Writer ;
2525import java .nio .charset .StandardCharsets ;
2626import java .nio .file .Files ;
27+ import java .nio .file .Path ;
2728import java .nio .file .Paths ;
2829import java .nio .file .StandardCopyOption ;
2930import java .util .Iterator ;
@@ -194,6 +195,11 @@ public synchronized void persist() {
194195 MixAll .fsyncDirectory (Paths .get (bakFile .getParent ()));
195196 }
196197
198+ File dir = new File (Path .of (config ).getParent ().toString ());
199+ if (!dir .exists ()) {
200+ Files .createDirectories (dir .toPath ());
201+ }
202+
197203 // persist metrics file
198204 StringWriter stringWriter = new StringWriter ();
199205 write0 (stringWriter );
Original file line number Diff line number Diff line change 2020import java .io .RandomAccessFile ;
2121import java .nio .charset .StandardCharsets ;
2222import java .nio .file .Files ;
23+ import java .nio .file .Path ;
2324import java .nio .file .Paths ;
2425import java .nio .file .StandardCopyOption ;
2526import java .util .Map ;
@@ -105,6 +106,11 @@ public synchronized void persist() {
105106 MixAll .fsyncDirectory (Paths .get (bakFile .getParent ()));
106107 }
107108
109+ File dir = new File (Path .of (config ).getParent ().toString ());
110+ if (!dir .exists ()) {
111+ Files .createDirectories (dir .toPath ());
112+ }
113+
108114 try (RandomAccessFile randomAccessFile = new RandomAccessFile (config , "rw" )) {
109115 randomAccessFile .write (jsonString .getBytes (StandardCharsets .UTF_8 ));
110116 randomAccessFile .getChannel ().force (true );
Original file line number Diff line number Diff line change 2424import java .io .Writer ;
2525import java .nio .charset .StandardCharsets ;
2626import java .nio .file .Files ;
27+ import java .nio .file .Path ;
2728import java .nio .file .Paths ;
2829import java .nio .file .StandardCopyOption ;
2930import java .util .ArrayList ;
@@ -238,6 +239,11 @@ public void setDataVersion(DataVersion dataVersion) {
238239 MixAll .fsyncDirectory (Paths .get (bakFile .getParent ()));
239240 }
240241
242+ File dir = new File (Path .of (config ).getParent ().toString ());
243+ if (!dir .exists ()) {
244+ Files .createDirectories (dir .toPath ());
245+ }
246+
241247 // persist metrics file
242248 StringWriter stringWriter = new StringWriter ();
243249 write0 (stringWriter );
You can’t perform that action at this time.
0 commit comments