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)