This is an automated email from the ASF dual-hosted git repository.
zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new ddd8e9c947 Revert "[fix-#11726] fix error when set connection proerty
both in the URL an…" (#17080)
ddd8e9c947 is described below
commit ddd8e9c9478dc6e171e46888abc1a5c77b361b5c
Author: Wenjun Ruan <[email protected]>
AuthorDate: Tue Mar 25 12:42:46 2025 +0800
Revert "[fix-#11726] fix error when set connection proerty both in the URL
an…" (#17080)
This reverts commit 8665951981b48fad051fe7457af5fddf8e61de87.
---
.../datasource/presto/param/PrestoDataSourceProcessor.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/main/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessor.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/main/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessor.java
index f72bdb2b64..b5dc8fd09c 100644
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/main/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessor.java
+++
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-presto/src/main/java/org/apache/dolphinscheduler/plugin/datasource/presto/param/PrestoDataSourceProcessor.java
@@ -102,11 +102,10 @@ public class PrestoDataSourceProcessor extends
AbstractDataSourceProcessor {
@Override
public String getJdbcUrl(ConnectionParam connectionParam) {
PrestoConnectionParam prestoConnectionParam = (PrestoConnectionParam)
connectionParam;
- /**
- * return jdbc url without other parameters, avoid to assign same
parameters both in URL and properties.
- * or else got error msg: Connection property '...' is both in the URL
and an argument
- * ref to <a
href="https://prestodb.io/docs/current/installation/jdbc.html">Presto JDBC
Driver</>
- */
+ if (MapUtils.isNotEmpty(prestoConnectionParam.getOther())) {
+ return String.format("%s?%s", prestoConnectionParam.getJdbcUrl(),
+ transformOther(prestoConnectionParam.getOther()));
+ }
return prestoConnectionParam.getJdbcUrl();
}