[
https://issues.apache.org/jira/browse/FLINK-27113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518750#comment-17518750
]
haojiawei commented on FLINK-27113:
-----------------------------------
Can I use flink-connector-jdbc_1.15.jar with Flink 1.14 version.
> Flink Sql Client CREATE CATALOG 'type'='jdbc', 'base-url' =
> 'jdbc:mysql://ip:port', ERROR MySQLDialect is not supported
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-27113
> URL: https://issues.apache.org/jira/browse/FLINK-27113
> Project: Flink
> Issue Type: Bug
> Components: Connectors / JDBC
> Affects Versions: 1.14.0
> Reporter: haojiawei
> Priority: Major
>
> Flink Sql Client CREATE CATALOG 'type'='jdbc', 'base-url' =
> 'jdbc:mysql://ip:port', ERROR MySQLDialect is not supported
> Caused by: java.lang.UnsupportedOperationException: Catalog for
> 'org.apache.flink.connector.jdbc.dialect.MySQLDialect@28f4f300' is not
> supported yet.
> at
> org.apache.flink.connector.jdbc.catalog.JdbcCatalogUtils.createCatalog(JdbcCatalogUtils.java:52)
> ~[flink-connector-jdbc_2.12-1.14.4.jar:1.14.4]
> at
> org.apache.flink.connector.jdbc.catalog.JdbcCatalog.<init>(JdbcCatalog.java:52)
> ~[flink-connector-jdbc_2.12-1.14.4.jar:1.14.4]
> at
> org.apache.flink.connector.jdbc.catalog.factory.JdbcCatalogFactory.createCatalog(JdbcCatalogFactory.java:77)
> ~[flink-connector-jdbc_2.12-1.14.4.jar:1.14.4]
> at
> org.apache.flink.table.factories.FactoryUtil.createCatalog(FactoryUtil.java:287)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.createCatalog(TableEnvironmentImpl.java:1292)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1122)
> ~[flink-table_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209)
> ~[flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88)
> ~[flink-sql-client_2.12-1.14.0.jar:1.14.0]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209)
> ~[flink-sql-client_2.12-1.14.0.jar:1.14.0]
> ... 11 more
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
