diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnectionHandler.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnectionHandler.java index d1a5fabe1..37099d6ba 100644 --- a/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnectionHandler.java +++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/MySQLConnectionHandler.java @@ -171,6 +171,18 @@ public class MySQLConnectionHandler extends BackendAsyncHandler { if (respHand != null) { respHand.errorResponse(data, source); } 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, source); + if (session != null) { + LOGGER.warn("no handler process the execute sql err,front conn {}", session.getSource()); + } + + } catch (RuntimeException e) { + LOGGER.info("error handle error-packet", e); + } closeNoHandler(); } }