You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/12/15 03:19:19 UTC
[iotdb] 01/02: add initialize state check when create snapshot
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch rel/1.0
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2a4817eb4e4c29c4a10f0246154ab002df7d35c0
Author: Marccos <15...@qq.com>
AuthorDate: Wed Dec 14 11:35:02 2022 +0800
add initialize state check when create snapshot
---
.../iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java | 6 ++++++
.../iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java | 6 ++++++
2 files changed, 12 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java
index 0cf41e3fd8..fa3db2d191 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java
@@ -437,6 +437,12 @@ public class SchemaRegionMemoryImpl implements ISchemaRegion {
// currently, this method is only used for cluster-ratis mode
@Override
public synchronized boolean createSnapshot(File snapshotDir) {
+ if (!initialized) {
+ logger.warn(
+ "Failed to create snapshot of schemaRegion {}, because thi schemaRegion has not been initialized.",
+ schemaRegionId);
+ return false;
+ }
logger.info("Start create snapshot of schemaRegion {}", schemaRegionId);
boolean isSuccess = true;
long startTime = System.currentTimeMillis();
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java
index 1146b04f07..a8528c72d2 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java
@@ -424,6 +424,12 @@ public class SchemaRegionSchemaFileImpl implements ISchemaRegion {
@Override
public boolean createSnapshot(File snapshotDir) {
+ if (!initialized) {
+ logger.warn(
+ "Failed to create snapshot of schemaRegion {}, because thi schemaRegion has not been initialized.",
+ schemaRegionId);
+ return false;
+ }
logger.info("Start create snapshot of schemaRegion {}", schemaRegionId);
boolean isSuccess = true;
long startTime = System.currentTimeMillis();