You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/05/09 10:24:24 UTC
[iotdb] branch master updated: [IOTDB-3125] IT case report Error RejectedExecutionException (#5838)
This is an automated email from the ASF dual-hosted git repository.
haonan 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 d64d945f4a [IOTDB-3125] IT case report Error RejectedExecutionException (#5838)
d64d945f4a is described below
commit d64d945f4a04c368a8e8863bb7c1f0e1e72195c6
Author: Jamber <ja...@sina.com>
AuthorDate: Mon May 9 18:24:18 2022 +0800
[IOTDB-3125] IT case report Error RejectedExecutionException (#5838)
Co-authored-by: haiyi.zb <ha...@alibaba-inc.com>
---
server/src/main/java/org/apache/iotdb/db/wal/WALManager.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/wal/WALManager.java b/server/src/main/java/org/apache/iotdb/db/wal/WALManager.java
index e0ac6f2de9..8468fc6cc1 100644
--- a/server/src/main/java/org/apache/iotdb/db/wal/WALManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/wal/WALManager.java
@@ -163,6 +163,10 @@ public class WALManager implements IService {
return;
}
+ if (walDeleteThread == null) {
+ return;
+ }
+
Future<?> future = walDeleteThread.submit(this::deleteOutdatedFiles);
try {
future.get();
@@ -203,6 +207,7 @@ public class WALManager implements IService {
if (walDeleteThread != null) {
shutdownThread(walDeleteThread, ThreadName.WAL_DELETE);
+ walDeleteThread = null;
}
clear();
}