diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java index f5de226cc41d5..9ffb29e77f3ce 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java @@ -303,7 +303,7 @@ public void stop() { stopped = true; try { if (!threadSemaphore.tryAcquire(30, TimeUnit.SECONDS)) { - logger.error("{}: Dispatcher for {} didn't stop after 30s.", impl.getThisNode(), peer); + logger.info("{}: Dispatcher for {} didn't stop after 30s.", impl.getThisNode(), peer); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotTaker.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotTaker.java index 5712e989a77d1..7f046940afe75 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotTaker.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotTaker.java @@ -147,7 +147,10 @@ public static boolean clearSnapshotOfDataRegion(DataRegion dataRegion) { pathBuilder.append(File.separator).append(dataRegion.getDatabaseName()); pathBuilder.append(IoTDBConstant.FILE_NAME_SEPARATOR).append(dataRegion.getDataRegionId()); try { - FileUtils.recursivelyDeleteFolder(pathBuilder.toString()); + String path = pathBuilder.toString(); + if (new File(path).exists()) { + FileUtils.recursivelyDeleteFolder(path); + } } catch (IOException e) { allSuccess = false; LOGGER.warn( diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALBuffer.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALBuffer.java index 742824a0fabe6..775a99867e1f1 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALBuffer.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALBuffer.java @@ -197,8 +197,9 @@ public void setBufferSize(int size) { @Override public void write(WALEntry walEntry) { if (isClosed) { - logger.error( - "Fail to write WALEntry into wal node-{} because this node is closed.", identifier); + logger.warn( + "Fail to write WALEntry into wal node-{} because this node is closed. It's ok to see this log during data region deletion.", + identifier); walEntry.getWalFlushListener().fail(new WALNodeClosedException(identifier)); return; }