未验证 提交 ff953d36 编写于 作者: B Beyyes 提交者: GitHub

add more logs for snapshot (#8298)

上级 f9360c53
......@@ -405,7 +405,7 @@ public class ConfigPlanExecutor {
try {
takeSnapshotResult = x.processTakeSnapshot(snapshotDir);
} catch (TException | IOException e) {
LOGGER.error(e.getMessage());
LOGGER.error("Take snapshot error: {}", e.getMessage());
takeSnapshotResult = false;
} finally {
// If any snapshot fails, the whole fails
......@@ -415,6 +415,9 @@ public class ConfigPlanExecutor {
}
}
});
if (result.get()) {
LOGGER.info("Task snapshot success, snapshotDir: {}", snapshotDir);
}
return result.get();
}
......@@ -426,6 +429,7 @@ public class ConfigPlanExecutor {
return;
}
AtomicBoolean result = new AtomicBoolean(true);
snapshotProcessorList
.parallelStream()
.forEach(
......@@ -433,9 +437,13 @@ public class ConfigPlanExecutor {
try {
x.processLoadSnapshot(latestSnapshotRootDir);
} catch (TException | IOException e) {
LOGGER.error(e.getMessage());
result.set(false);
LOGGER.error("Load snapshot error: {}", e.getMessage());
}
});
if (result.get()) {
LOGGER.info("Load snapshot success, latestSnapshotRootDir: {}", latestSnapshotRootDir);
}
}
private DataSet getSchemaNodeManagementPartition(ConfigPhysicalPlan req) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册