[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yuan Zhu updated FLINK-26437: ----------------------------- Attachment: image-2022-03-03-10-03-50-763.png > Cannot discover a connector using option: 'connector'='jdbc' > ------------------------------------------------------------ > > Key: FLINK-26437 > URL: https://issues.apache.org/jira/browse/FLINK-26437 > Project: Flink > Issue Type: Bug > Components: Table SQL / API > Affects Versions: 1.13.6 > Reporter: Arindam Bhattacharjee > Priority: Major > Labels: sql-api, table-api > Attachments: image-2022-03-03-10-03-50-763.png > > Original Estimate: 24h > Remaining Estimate: 24h > > Hi Team, > When I was running SQL in Flink SQL-API, was getting the below error - > *Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a > connector using option: 'connector'='jdbc'* > at > org.apache.flink.table.factories.FactoryUtil.enrichNoMatchingConnectorError(FactoryUtil.java:467) > at > org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:441) > at > org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:167) > ... 32 more > Caused by: org.apache.flink.table.api.ValidationException: Could not find any > factory for identifier 'jdbc' that implements > 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath. > Available factory identifiers are: > blackhole > datagen > filesystem > kafka > print > upsert-kafka > at > org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:319) > at > org.apache.flink.table.factories.FactoryUtil.enrichNoMatchingConnectorError(FactoryUtil.java:463) > ... 34 more > ------------------------ > > SQL I was using - > _CREATE TABLE pvuv_sink (_ > _dt varchar PRIMARY KEY,_ > _pv BIGINT,_ > _uv BIGINT_ > _) WITH (_ > _'connector' = 'jdbc',_ > _'url' = 'jdbc:mysql://localhost:3306/flinksql_test',_ > _'table-name' = 'pvuv_sink',_ > _'username' = 'root',_ > _'password' = 'xxxxxx',_ > _'sink.buffer-flush.max-rows' = '1'_ > _);_ -- This message was sent by Atlassian Jira (v8.20.1#820001)