From 5d0e510138c25b120cbcbc34697f8234dcbb2ea3 Mon Sep 17 00:00:00 2001
From: James <lijibing@selectdb.com>
Date: Wed, 25 Dec 2024 10:25:00 +0800
Subject: [PATCH] [fix](regression)Add log for Reach limit of connections
 (#45887)

### What problem does this PR solve?

Add log to help investigate Reach limit of connections error.

Issue Number: close #xxx

Related PR: #xxx

Problem Summary:

### Release note

None
---
 .../src/main/java/org/apache/doris/qe/ConnectScheduler.java   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java
index 43fa4dddca7844..f7b2e1790cae6c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java
@@ -93,6 +93,8 @@ public boolean submit(ConnectContext context) {
     // Register one connection with its connection id.
     public boolean registerConnection(ConnectContext ctx) {
         if (numberConnection.incrementAndGet() > maxConnections) {
+            LOG.info("Number connection {} has reach upper limit {}. Connection map : [{}]",
+                    numberConnection.get(), maxConnections, connectionMap);
             numberConnection.decrementAndGet();
             return false;
         }
@@ -100,6 +102,8 @@ public boolean registerConnection(ConnectContext ctx) {
         connByUser.putIfAbsent(ctx.getQualifiedUser(), new AtomicInteger(0));
         AtomicInteger conns = connByUser.get(ctx.getQualifiedUser());
         if (conns.incrementAndGet() > ctx.getEnv().getAuth().getMaxConn(ctx.getQualifiedUser())) {
+            LOG.info("User {}'s connection {} has reached upper limit {}. connByUser: [{}]", ctx.getQualifiedUser(),
+                    conns.get(), ctx.getEnv().getAuth().getMaxConn(ctx.getQualifiedUser()), connByUser);
             conns.decrementAndGet();
             numberConnection.decrementAndGet();
             return false;