This is an automated email from the ASF dual-hosted git repository.
wangchao316 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 19fff1d5d7 [IOTDB-3632] Add log for snapshot taker and loader (#6401)
19fff1d5d7 is described below
commit 19fff1d5d785227d4404acfc97f76cc28db93b8f
Author: Liu Xuxin <[email protected]>
AuthorDate: Thu Jun 23 20:10:06 2022 +0800
[IOTDB-3632] Add log for snapshot taker and loader (#6401)
[IOTDB-3632] Add log for snapshot taker and loader (#6401)
---
.../java/org/apache/iotdb/db/engine/snapshot/SnapshotLoader.java | 7 +++++++
.../java/org/apache/iotdb/db/engine/snapshot/SnapshotTaker.java | 6 ++++++
2 files changed, 13 insertions(+)
diff --git
a/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotLoader.java
b/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotLoader.java
index 7283e621ba..8067da84d4 100644
---
a/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotLoader.java
+++
b/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotLoader.java
@@ -72,8 +72,14 @@ public class SnapshotLoader {
* @return
*/
public DataRegion loadSnapshotForStateMachine() {
+ LOGGER.info(
+ "Loading snapshot for {}-{}, source directory is {}",
+ storageGroupName,
+ dataRegionId,
+ snapshotPath);
try {
deleteAllFilesInDataDirs();
+ LOGGER.info("Remove all data files in original data dir");
} catch (IOException e) {
return null;
}
@@ -83,6 +89,7 @@ public class SnapshotLoader {
if (sourceDataDir.exists()) {
try {
createLinksFromSnapshotDirToDataDir(sourceDataDir);
+ LOGGER.info("Move data files from snapshot to data directory");
} catch (IOException | DiskSpaceInsufficientException e) {
LOGGER.error(
"Exception occurs when creating links from snapshot directory to
data directory", e);
diff --git
a/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotTaker.java
b/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotTaker.java
index 02f69266c6..4796b66ac8 100644
---
a/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotTaker.java
+++
b/server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotTaker.java
@@ -118,6 +118,12 @@ public class SnapshotTaker {
manager.readUnlock();
}
+ LOGGER.info(
+ "Successfully take snapshot for {}-{}, snapshot directory is {}",
+ dataRegion.getLogicalStorageGroupName(),
+ dataRegion.getDataRegionId(),
+ snapshotDirPath);
+
return true;
}