This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch DeleteInsertBug in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit acb1b249bfe359c87cb7cb7688b4993919f73f5f Author: JackieTien97 <[email protected]> AuthorDate: Wed Apr 22 10:24:06 2020 +0800 init --- server/src/main/java/org/apache/iotdb/db/metadata/MManager.java | 1 - .../main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 7 +++++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java index 80db035..348fcb8 100644 --- a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java +++ b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java @@ -142,7 +142,6 @@ public class MManager { try { tagLogFile = new TagLogFile(config.getSchemaDir(), MetadataConstant.TAG_LOG); - initFromLog(logFile); if (config.isEnableParameterAdapter()) { // storage group name -> the series number diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java index fb3c57d..0c0cb57 100644 --- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java +++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java @@ -81,6 +81,8 @@ import org.slf4j.LoggerFactory; import java.io.File; import java.io.IOException; import java.util.*; +import java.util.concurrent.TimeUnit; + import static org.apache.iotdb.db.conf.IoTDBConstant.*; import static org.apache.iotdb.tsfile.common.constant.TsFileConstant.PATH_SEPARATOR; import static org.apache.iotdb.tsfile.common.constant.TsFileConstant.TSFILE_SUFFIX; @@ -725,6 +727,11 @@ public class PlanExecutor implements IPlanExecutor { LeafMNode measurementNode = (LeafMNode) node.getChild(measurement); schemas[i] = measurementNode.getSchema(); } + try { + TimeUnit.SECONDS.sleep(4); + } catch (InterruptedException e) { + e.printStackTrace(); + } insertPlan.setSchemas(schemas); StorageEngine.getInstance().insert(insertPlan); } catch (StorageEngineException | MetadataException e) {
