@@ -118,7 +118,8 @@ public boolean submit(ConnectContext context) {
118
118
public Pair <Boolean , String > registerConnection (ConnectContext ctx ) {
119
119
if (numberConnection .get () >= maxConnections .get ()) {
120
120
return new Pair <>(false , "Reach cluster-wide connection limit, qe_max_connection=" + maxConnections +
121
- ", connectionMap.size=" + connectionMap .size ());
121
+ ", connectionMap.size=" + connectionMap .size () +
122
+ ", node=" + ctx .getGlobalStateMgr ().getNodeMgr ().getSelfNode ());
122
123
}
123
124
// Check user
124
125
connByUser .computeIfAbsent (ctx .getQualifiedUser (), k -> new AtomicInteger (0 ));
@@ -133,7 +134,8 @@ public Pair<Boolean, String> registerConnection(ConnectContext ctx) {
133
134
return new Pair <>(false , "Reach user-level(qualifiedUser: " + ctx .getQualifiedUser () +
134
135
", currUserIdentity: " + ctx .getCurrentUserIdentity () + ") connection limit, " +
135
136
"currentUserMaxConn=" + currentUserMaxConn + ", connectionMap.size=" + connectionMap .size () +
136
- ", connByUser.totConn=" + connByUser .values ().stream ().mapToInt (AtomicInteger ::get ).sum ());
137
+ ", connByUser.totConn=" + connByUser .values ().stream ().mapToInt (AtomicInteger ::get ).sum () +
138
+ ", node=" + ctx .getGlobalStateMgr ().getNodeMgr ().getSelfNode ());
137
139
}
138
140
numberConnection .incrementAndGet ();
139
141
connByUser .get (ctx .getQualifiedUser ()).incrementAndGet ();
0 commit comments