File tree Expand file tree Collapse file tree 3 files changed +5
-5
lines changed
integration-test/src/test/java/org/apache/iotdb/db/it
iotdb-core/datanode/src/main/java/org/apache/iotdb/db Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ public void setUp() throws Exception {
9898
9999 @ After
100100 public void tearDown () throws Exception {
101- deleteSG ();
101+ deletedb ();
102102 EnvFactory .getEnv ().cleanClusterEnvironment ();
103103
104104 if (!deleteDir ()) {
Original file line number Diff line number Diff line change @@ -272,12 +272,12 @@ private void asyncRecover(List<Future<Void>> futures) {
272272 /** get StorageGroup -> DataRegionIdList map from data/system directory. */
273273 public Map <String , List <DataRegionId >> getLocalDataRegionInfo () {
274274 File system = SystemFileFactory .INSTANCE .getFile (systemDir );
275- File [] sgDirs = system .listFiles ();
275+ File [] dbDirs = system .listFiles ();
276276 Map <String , List <DataRegionId >> localDataRegionInfo = new HashMap <>();
277- if (sgDirs == null ) {
277+ if (dbDirs == null ) {
278278 return localDataRegionInfo ;
279279 }
280- for (File sgDir : sgDirs ) {
280+ for (File sgDir : dbDirs ) {
281281 if (!sgDir .isDirectory ()) {
282282 continue ;
283283 }
Original file line number Diff line number Diff line change @@ -109,7 +109,7 @@ public static void main(String[] args) throws IOException {
109109
110110 List <File > dbDirs =
111111 Arrays .asList (Objects .requireNonNull (seqDataDir .listFiles (File ::isDirectory )));
112- for (File sgDir : Objects .requireNonNull (sgDirs )) {
112+ for (File sgDir : Objects .requireNonNull (dbDirs )) {
113113 if (!checkIsDirectory (sgDir )) {
114114 continue ;
115115 }
You can’t perform that action at this time.
0 commit comments