Update server/server.go

Co-authored-by: djshow832 <[email protected]>
pingcap · Apr 1, 2021 · 003448c · 003448c
1 parent 0c18e2a
commit 003448c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -482,7 +482,7 @@ func (s *Server) onConn(conn *clientConn) {
 	err = plugin.ForeachPlugin(plugin.Audit, func(p *plugin.Plugin) error {
 		// Audit plugin may be disabled before a conn is created, leading no connectionInfo in sessionVars.
 		if sessionVars.ConnectionInfo == nil {
-			conn.ctx.GetSessionVars().ConnectionInfo = conn.connectInfo()
+			sessionVars.ConnectionInfo = conn.connectInfo()
 		}
 		authPlugin := plugin.DeclareAuditManifest(p.Manifest)
 		if authPlugin.OnConnectionEvent != nil {