diff --git a/src/main/java/com/actiontech/dble/services/mysqlsharding/MysqlBackendLogicHandler.java b/src/main/java/com/actiontech/dble/services/mysqlsharding/MysqlBackendLogicHandler.java index a3424322b..16d9253d0 100644 --- a/src/main/java/com/actiontech/dble/services/mysqlsharding/MysqlBackendLogicHandler.java +++ b/src/main/java/com/actiontech/dble/services/mysqlsharding/MysqlBackendLogicHandler.java @@ -110,6 +110,18 @@ public class MysqlBackendLogicHandler { if (respHand != null) { respHand.errorResponse(data, service); } else { + try { + ErrorPacket errPkg = new ErrorPacket(); + errPkg.read(data); + String errMsg = "errNo:" + errPkg.getErrNo() + " " + new String(errPkg.getMessage()); + LOGGER.warn("no handler process the execute sql err,just close it, sql error:{},back con:{}", errMsg, service); + if (service.getSession() != null) { + LOGGER.warn("no handler process the execute sql err,front conn {}", service.getSession().getSource()); + } + + } catch (RuntimeException e) { + LOGGER.info("error handle error-packet", e); + } closeNoHandler(); } }