diff --git a/src/observer/mysql/obmp_default.h b/src/observer/mysql/obmp_default.h index 86ab8c1e351954450dc8d1946f4a9489e1390f7c..ecfafb7b879bcf0a4855516606f8d8c0f776471e 100644 --- a/src/observer/mysql/obmp_default.h +++ b/src/observer/mysql/obmp_default.h @@ -37,6 +37,7 @@ public: } else { SERVER_LOG(WARN, "MySQL command not supported", "cmd", pkt.get_cmd()); } + disconnect(); } return ret; }