diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java index cb765e58e4..13d65c055e 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java @@ -23,6 +23,7 @@ import com.google.common.collect.Lists; import org.apache.commons.lang3.StringUtils; +import org.apache.inlong.manager.pojo.util.MySQLSensitiveUrlUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -76,6 +77,7 @@ private static Connection establishDatabaseConnection(String url, String user, S } try { UrlVerificationUtils.extractHostAndValidatePortFromJdbcUrl(url, OCEANBASE_JDBC_PREFIX); + url = MySQLSensitiveUrlUtils.filterSensitive(url); Class.forName(OCEANBASE_DRIVER_CLASS); conn = DriverManager.getConnection(url, user, password); } catch (Exception e) {