[iotdb] branch tiered_storage updated: reviewd migration part

[xingtanzjr]

This is an automated email from the ASF dual-hosted git repository.

xingtanzjr pushed a commit to branch tiered_storage
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/tiered_storage by this push:
     new 690691260e6 reviewd migration part
690691260e6 is described below

commit 690691260e6262acb1e272d5199cbc56bc39d703
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Tue May 23 11:20:25 2023 +0800

    reviewd migration part
---
 .../iotdb/db/engine/migration/MigrationTaskManager.java    |  1 +
 .../iotdb/db/engine/migration/RemoteMigrationTask.java     | 14 ++++++--------
 2 files changed, 7 insertions(+), 8 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/migration/MigrationTaskManager.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/migration/MigrationTaskManager.java
index 37957aa8b0a..ddf3f66159f 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/migration/MigrationTaskManager.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/migration/MigrationTaskManager.java
@@ -63,6 +63,7 @@ public class MigrationTaskManager implements IService {
   @Override
   public void start() throws StartupException {
     if (iotdbConfig.getTierDataDirs().length == 1) {
+      logger.info("tiered storage status: disable");
       return;
     }
     scheduler =
diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/migration/RemoteMigrationTask.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/migration/RemoteMigrationTask.java
index aeb5cda61bd..65aeb4d9181 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/migration/RemoteMigrationTask.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/migration/RemoteMigrationTask.java
@@ -47,14 +47,12 @@ public class RemoteMigrationTask extends MigrationTask {
     } finally {
       tsFile.readUnlock();
     }
-    // replace TsFile path
-    //    tsFile.writeLock();
-    //    try {
-    //      tsFile.setFile(destTsFile);
-    //    } finally {
-    //      tsFile.writeUnlock();
-    //    }
     // clear src files
-    srcTsFile.delete();
+    tsFile.writeLock();
+    try {
+      srcTsFile.delete();
+    } finally {
+      tsFile.writeUnlock();
+    }
   }
 }