[jira] [Created] (FLINK-19851) flink sql client connector type jdbc exception

["hulingchan (Jira)" <ji...@apache.org>]

hulingchan created FLINK-19851:
----------------------------------

             Summary: flink sql client connector type jdbc exception
                 Key: FLINK-19851
                 URL: https://issues.apache.org/jira/browse/FLINK-19851
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Client
    Affects Versions: 1.11.1
         Environment: hardware: Mac Pro

software: MacOS

 
            Reporter: hulingchan


When I want to experience the SQL client using jdbc as the source, there is a problem.

*run command*：

./sql-client.sh embedded -e ../conf/sql-client-demo.yaml

*sql-client-demo.yaml conttent*：
{code:java}
tables:
  - name: mysql_test
    type: source-table
    connector:
        type: jdbc
        property-version: 1
        url: jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&autoReconnect=true&serverTimezone=Asia/Shanghai
        table: book_info
        driver: com.mysql.jdbc.Driver
        username: lloo
        password: dsfsdf
{code}
*log below*：
{code:java}
No default environment specified.
 Searching for 'flink-1.11.1/conf/sql-client-defaults.yaml'...found.
 Reading default environment from: file:flink-1.11.1/conf/sql-client-defaults.yaml
 Reading session environment from: file:flink-1.11.1/bin/../conf/sql-client-demo.yaml
Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
 Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could not create execution context.
 at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:870)
 at org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
 at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
 at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
 Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in
 the classpath.
Reason: Required context properties mismatch.
The following properties are requested:
 connector.driver=com.mysql.jdbc.Driver
 connector.password=123456
 connector.property-version=1
 connector.table=durotar_wx_user_info
 connector.type=jdbc
 connector.url=jdbc:mysql://qa.vm.com:3306/zh_portal?useUnicode=true&characterEncoding=utf8&autoReconnect=true&serverTimezone=Asia/Shanghai
 connector.username=root
The following factories have been considered:
 org.apache.flink.table.sources.CsvBatchTableSourceFactory
 org.apache.flink.table.sources.CsvAppendTableSourceFactory
 org.apache.flink.table.filesystem.FileSystemTableFactory
 at org.apache.flink.table.factories.TableFactoryService.filterByContext(TableFactoryService.java:322)
 at org.apache.flink.table.factories.TableFactoryService.filter(TableFactoryService.java:190)
 at org.apache.flink.table.factories.TableFactoryService.findSingleInternal(TableFactoryService.java:143)
 at org.apache.flink.table.factories.TableFactoryService.find(TableFactoryService.java:113)
 at org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:384)
 at org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$7(ExecutionContext.java:638)
 at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
 at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:636)
 at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:523)
 at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:183)
 at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:136)
 at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:859)
 ... 3 more
  
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)