[
https://issues.apache.org/jira/browse/FLINK-21841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JieFang.He updated FLINK-21841:
-------------------------------
Description:
When use sql-kafka with fat-jar（make flink-sql-connector-kafka_2.11 in user
jar） with flink 1.11.1 like
{code:java}
CREATE TABLE user_behavior (
user_id INT,
action STRING,
province INT,
ts TIMESTAMP(3)
) WITH (
'connector' = 'kafka',
'topic' = 'intopic',
'properties.bootstrap.servers' = 'kafkaserver:9092',
'properties.group.id' = 'testGroup',
'format' = 'csv',
'scan.startup.mode' = 'earliest-offset'
)
{code}
I get a exception
{code:java}
Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a
connector using option ''connector'='kafka''.
at
org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:329)
at
org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:118)
... 35 more
Caused by: org.apache.flink.table.api.ValidationException: Could not find any
factory for identifier 'kafka' that implements
'org.apache.flink.table.factories.DynamicTableSourceFactory' in the
classpath.Available factory identifiers are:datagen
{code}
It looks like the issue [FLINK-18076|http://example.com/] is not deal with all
exceptions
was:
When use sql-kafka with fat-jar（make flink-sql-connector-kafka_2.11 in user
jar） with flink 1.11.1 like
{code:java}
CREATE TABLE user_behavior (
user_id INT,
action STRING,
province INT,
ts TIMESTAMP(3)
) WITH (
'connector' = 'kafka',
'topic' = 'intopic',
'properties.bootstrap.servers' = 'kafkaserver:9092',
'properties.group.id' = 'testGroup',
'format' = 'csv',
'scan.startup.mode' = 'earliest-offset'
)
{code}
I get a exception
{code:java}
Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a
connector using option ''connector'='kafka''.
at
org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:329)
at
org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:118)
... 35 more
Caused by: org.apache.flink.table.api.ValidationException: Could not find any
factory for identifier 'kafka' that implements
'org.apache.flink.table.factories.DynamicTableSourceFactory' in the
classpath.Available factory identifiers are:datagen
{code}
It looks like the issue [FLINK-18076|http://example.com/] is not deal with all
exceptions
> Can not find kafka-connect with sql-kafka-connector
> ---------------------------------------------------
>
> Key: FLINK-21841
> URL: https://issues.apache.org/jira/browse/FLINK-21841
> Project: Flink
> Issue Type: Bug
> Reporter: JieFang.He
> Priority: Major
>
>
> When use sql-kafka with fat-jar（make flink-sql-connector-kafka_2.11 in user
> jar） with flink 1.11.1 like
> {code:java}
> CREATE TABLE user_behavior (
> user_id INT,
> action STRING,
> province INT,
> ts TIMESTAMP(3)
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'intopic',
> 'properties.bootstrap.servers' = 'kafkaserver:9092',
> 'properties.group.id' = 'testGroup',
> 'format' = 'csv',
> 'scan.startup.mode' = 'earliest-offset'
> )
> {code}
> I get a exception
> {code:java}
> Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a
> connector using option ''connector'='kafka''.
> at
> org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:329)
> at
> org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:118)
> ... 35 more
> Caused by: org.apache.flink.table.api.ValidationException: Could not find any
> factory for identifier 'kafka' that implements
> 'org.apache.flink.table.factories.DynamicTableSourceFactory' in the
> classpath.Available factory identifiers are:datagen
> {code}
> It looks like the issue [FLINK-18076|http://example.com/] is not deal with
> all exceptions
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
