We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 371dbdd commit 6cfb037Copy full SHA for 6cfb037
src/main/java/com/actiontech/dble/backend/datasource/PhysicalDatasource.java
@@ -248,7 +248,7 @@ private void longIdleHeartBeat(ConcurrentLinkedQueue<BackendConnection> linkedQu
248
break;
249
} else if (con.isClosed()) {
250
continue;
251
- } else if (!con.isBorrowed()) { //if the connection is idle for a long time
+ } else if (con.getLastTime() < hearBeatTime) { //if the connection is idle for a long time
252
con.setBorrowed(true);
253
new ConnectionHeartBeatHandler().doHeartBeat(con);
254
} else {
0 commit comments