diff --git a/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java b/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java index 9ec8ef1..279b694 100755 --- a/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java +++ b/java/cost-accounting-benchmark/src/main/java/com/tsurugidb/benchmark/costaccounting/debug/DebugCommand.java @@ -202,6 +202,10 @@ private void tsubakuroResultSetClose() throws Exception { } } } catch (ServerException | IOException | InterruptedException e) { + var message = e.getMessage(); + if (message.contains("already closed")) { + return; + } LOG.error("thread error", e); throw new RuntimeException(e); } @@ -296,7 +300,7 @@ private void tsubakuroTransactionClose() throws Exception { if (message.contains("already closed")) { // wire return; } - if (message.contains("Server crashed")) { + if (message.contains("lost connection")) { return; } LOG.error("thread error", e);