diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/AbstractDebugSession.java b/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/AbstractDebugSession.java index cb1458ee75..22319ad0f4 100644 --- a/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/AbstractDebugSession.java +++ b/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/AbstractDebugSession.java @@ -96,8 +96,7 @@ public DBFunction executeFunction(DBFunction dbFunction) { } protected void acquireNewConnection(ConnectionSession connectionSession, - Supplier dataSourceSupplier) - throws Exception { + Supplier dataSourceSupplier) throws Exception { this.connectionSession = connectionSession; ConnectionConfig connectionConfig = (ConnectionConfig) ConnectionSessionUtil.getConnectionConfig(connectionSession); diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/DebuggerSession.java b/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/DebuggerSession.java index 0b51fc8890..2fcc67b2e3 100644 --- a/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/DebuggerSession.java +++ b/server/odc-service/src/main/java/com/oceanbase/odc/service/pldebug/session/DebuggerSession.java @@ -108,7 +108,7 @@ public DebuggerSession(DebuggeeSession debuggeeSession, StartPLDebugReq req, boo ddl = req.getAnonymousBlock(); this.syncEnabled = syncEnabled; - // Debugger must connect to the same database host with debuggee + // Debugger must connect to database host the same as debuggee acquireNewConnection(debuggeeSession.getConnectionSession(), () -> cloneDataSource(debuggeeSession.getNewDataSource())); try (Statement stmt = connection.createStatement()) {