You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "haojiawei (Jira)" <ji...@apache.org> on 2022/04/07 09:34:00 UTC

[jira] [Created] (FLINK-27113) Flink Sql Client CREATE CATALOG 'type'='jdbc', 'base-url' = 'jdbc:mysql://ip:port', ERROR MySQLDialect is not supported

haojiawei created FLINK-27113:
---------------------------------

             Summary: 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: Table SQL / Client
    Affects Versions: 1.14.0
            Reporter: haojiawei


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)