[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17500459#comment-17500459
]
Yuan Zhu commented on FLINK-26437:
----------------------------------
In my local env(wsl-ubuntu-20.04), I can run "sql-client.sh embedded" with
jars, which are listed below, in flink lib.
!image-2022-03-03-10-03-50-763.png!
And the sql is almost like yours:
{code:java}
CREATE TABLE source (
user_id varchar,
item_id varchar,
category_id varchar,
behavior varchar,
ts TIMESTAMP(3)
) WITH (
'connector' = 'kafka',
'topic' = 'test_json',
'scan.startup.mode' = 'earliest-offset',
'properties.bootstrap.servers' = 'localhost:9392',
'format' = 'json',
'json.ignore-parse-errors' = 'true',
'properties.group.id' = 'test');
CREATE TABLE user_details_fs WITH (
'connector' = 'filesystem',
'path' = 'file:///mnt/c/Users/zhuyuan/Desktop/',
'format' = 'parquet'
) LIKE source (EXCLUDING ALL);
insert into user_details_fs select * from source;{code}
> 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)
