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 ;
2827import java .nio .file .Paths ;
2928import java .nio .file .StandardCopyOption ;
3029import java .util .Iterator ;
@@ -195,7 +194,7 @@ public synchronized void persist() {
195194 MixAll .fsyncDirectory (Paths .get (bakFile .getParent ()));
196195 }
197196
198- File dir = new File (Path . of ( config ). getParent (). toString ());
197+ File dir = new File (configFile . getParent ());
199198 if (!dir .exists ()) {
200199 Files .createDirectories (dir .toPath ());
201200 }
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 ;
2423import java .nio .file .Paths ;
2524import java .nio .file .StandardCopyOption ;
2625import java .util .Map ;
@@ -106,7 +105,7 @@ public synchronized void persist() {
106105 MixAll .fsyncDirectory (Paths .get (bakFile .getParent ()));
107106 }
108107
109- File dir = new File (Path . of ( config ). getParent (). toString ());
108+ File dir = new File (configFile . getParent ());
110109 if (!dir .exists ()) {
111110 Files .createDirectories (dir .toPath ());
112111 }
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 ;
2827import java .nio .file .Paths ;
2928import java .nio .file .StandardCopyOption ;
3029import java .util .ArrayList ;
@@ -239,7 +238,7 @@ public void setDataVersion(DataVersion dataVersion) {
239238 MixAll .fsyncDirectory (Paths .get (bakFile .getParent ()));
240239 }
241240
242- File dir = new File (Path . of ( config ). getParent (). toString ());
241+ File dir = new File (configFile . getParent ());
243242 if (!dir .exists ()) {
244243 Files .createDirectories (dir .toPath ());
245244 }
You can’t perform that action at this time.
0 commit comments