Arindam Bhattacharjee created FLINK-26437:
---------------------------------------------
Summary: 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
Environment: PROD,DEV
Reporter: Arindam Bhattacharjee
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)
