diff --git a/server/handler.go b/server/handler.go
index 422a2ac3e..6cc582c58 100644
--- a/server/handler.go
+++ b/server/handler.go
@@ -177,7 +177,7 @@ func (h *Handler) handleKill(conn *mysql.Conn, query string) (bool, error) {
 
 	if s[1] == "query" {
 		logrus.Infof("kill query: id %v", id)
-		h.e.Catalog.KillConnection(uint32(id))
+		h.e.Catalog.Kill(id)
 	} else {
 		logrus.Infof("kill connection: id %v, pid: %v", conn.ConnectionID, id)
 		h.mu.Lock()