[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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' = 'xxxxxx',_
> _'sink.buffer-flush.max-rows' = '1'_
> _);_
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
