You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/11/28 03:55:20 UTC
[iotdb] branch master updated: Declare the type of result of Future
in StorageEngine (#2097)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin 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 de4536a Declare the type of result of Future in StorageEngine (#2097)
de4536a is described below
commit de4536ac6d6915b2d686a62d1881d22090b68fa9
Author: Benedict Jin <as...@apache.org>
AuthorDate: Sat Nov 28 11:54:53 2020 +0800
Declare the type of result of Future in StorageEngine (#2097)
---
server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
index 4fd8b57..ddb0895 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
@@ -29,7 +29,6 @@ import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
-import java.util.concurrent.Callable;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
@@ -188,9 +187,9 @@ public class StorageEngine implements IService {
* recover all storage group processors.
*/
List<StorageGroupMNode> sgNodes = IoTDB.metaManager.getAllStorageGroupNodes();
- List<Future> futures = new ArrayList<>();
+ List<Future<Void>> futures = new ArrayList<>();
for (StorageGroupMNode storageGroup : sgNodes) {
- futures.add(recoveryThreadPool.submit((Callable<Void>) () -> {
+ futures.add(recoveryThreadPool.submit(() -> {
try {
StorageGroupProcessor processor = new StorageGroupProcessor(systemDir,
storageGroup.getFullPath(), fileFlushPolicy);
@@ -207,7 +206,7 @@ public class StorageEngine implements IService {
return null;
}));
}
- for (Future future : futures) {
+ for (Future<Void> future : futures) {
try {
future.get();
} catch (ExecutionException e) {