[jira] [Comment Edited] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'
[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500267#comment-17500267 ] Arindam Bhattacharjee edited comment on FLINK-26437 at 3/2/22, 4:14 PM: [~straw] I have run with mode - sql client and jar as well through table api. Also if you have any sample code where we are getting data from kafka and writing the same to filesystem , which can help me to refer. was (Author: JIRAUSER285980): [~straw] I have run with mode - sql client and jar as well through table api. > 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 > 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' = 'xx',_ > _'sink.buffer-flush.max-rows' = '1'_ > _);_ -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'
[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500105#comment-17500105 ] Yuan Zhu edited comment on FLINK-26437 at 3/2/22, 12:28 PM: You can try adding [hadoop jar|https://repository.cloudera.com/artifactory/cloudera-repos/org/apache/flink/flink-shaded-hadoop-3-uber/3.1.1.7.2.1.0-327-9.0/flink-shaded-hadoop-3-uber-3.1.1.7.2.1.0-327-9.0.jar] to your flink lib directory. was (Author: straw): You can try add [hadoop jar|https://repository.cloudera.com/artifactory/cloudera-repos/org/apache/flink/flink-shaded-hadoop-3-uber/3.1.1.7.2.1.0-327-9.0/flink-shaded-hadoop-3-uber-3.1.1.7.2.1.0-327-9.0.jar] to your flink lib directory. > 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 > 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' = 'xx',_ > _'sink.buffer-flush.max-rows' = '1'_ > _);_ -- This message was sent by Atlassian Jira (v8.20.1#820001)
