提交 9a4cd8b8 编写于 作者: Q qiaojialin

add exception catch in recover

上级 1e8f6603
......@@ -115,12 +115,17 @@ public class StorageEngine implements IService {
List<Future> futures = new ArrayList<>();
for (MNode storageGroup : sgNodes) {
futures.add(recoveryThreadPool.submit((Callable<Void>) () -> {
StorageGroupProcessor processor = new StorageGroupProcessor(systemDir,
storageGroup.getFullPath());
processor.setDataTTL(storageGroup.getDataTTL());
processorMap.put(storageGroup.getFullPath(), processor);
logger.info("Storage Group Processor {} is recovered successfully",
storageGroup.getFullPath());
try {
StorageGroupProcessor processor = new StorageGroupProcessor(systemDir,
storageGroup.getFullPath());
processor.setDataTTL(storageGroup.getDataTTL());
processorMap.put(storageGroup.getFullPath(), processor);
logger.info("Storage Group Processor {} is recovered successfully",
storageGroup.getFullPath());
} catch (Exception e) {
logger.error("meet error when recovering", e);
throw e;
}
return null;
}));
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册