Sergey Nuyanzin created FLINK-33800:
---------------------------------------
Summary: Allow passing parameters to database via jdbc url
Key: FLINK-33800
URL: https://issues.apache.org/jira/browse/FLINK-33800
Project: Flink
Issue Type: Improvement
Components: Connectors / JDBC
Affects Versions: jdbc-3.1.1
Reporter: Sergey Nuyanzin
Assignee: Sergey Nuyanzin
Currently it does not allow to pass extra properties e.g.
an attempt to connect to
{{jdbc:postgresql://...?sslmode=require}}
fails with
{noformat}
Caused by: org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed
to fetchResults.
at
org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceImpl.java:229)
at
org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:83)
... 48 more
Caused by: org.apache.flink.table.gateway.service.utils.SqlExecutionException:
Failed to execute the operation b70b5cf7-7068-4eb6-83a4-78aed36dbd35.
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
at
org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source)
{noformat}
because of of a logic at
{{org.apache.flink.connector.jdbc.catalog.JdbcCatalogUtils#validateJdbcUrl}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
