未验证 提交 053ae3f8 编写于 作者: wu-sheng's avatar wu-sheng 提交者: GitHub

Fix #9440, `batchDAO.endOfFlush();` should be called after all executions are ready. (#9441)

上级 caa6a0de
......@@ -136,8 +136,9 @@ public enum PersistenceTimer {
.whenComplete(($1, $2) -> executeLatencyTimer.close());
}, prepareExecutorService);
}).toArray(CompletableFuture[]::new));
batchDAO.endOfFlush();
future.whenComplete((unused, throwable) -> {
batchDAO.endOfFlush();
allTimer.close();
if (log.isDebugEnabled()) {
log.debug(
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册