diff --git a/proxy/server/executor_handle.go b/proxy/server/executor_handle.go index afd46a63..0e73202c 100644 --- a/proxy/server/executor_handle.go +++ b/proxy/server/executor_handle.go @@ -137,7 +137,7 @@ func (se *SessionExecutor) doMultiStmts(reqCtx *util.RequestContext, sql string) if err = se.session.writeResponse(response); err != nil { log.Warn("session write response error, error: %v", err) se.session.Close() - return r, errRet + return r, err } } }