zhisheng created FLINK-19995: -------------------------------- Summary: 【Flink SQL Client】Use Flink Kafka Connector has more one exception Key: FLINK-19995 URL: https://issues.apache.org/jira/browse/FLINK-19995 Project: Flink Issue Type: Bug Components: Connectors / Kafka, Table SQL / Client Affects Versions: 1.12.0 Reporter: zhisheng Attachments: image-2020-11-05-17-35-10-103.png, image-2020-11-05-17-37-21-610.png, image-2020-11-05-17-40-05-630.png, image-2020-11-05-17-41-01-319.png
when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run sql job has an exception like picture2 !image-2020-11-05-17-35-10-103.png|width=658,height=251! !image-2020-11-05-17-37-21-610.png|width=812,height=600! {code:java} [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer {code} when i add flink-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, it run has another exception !image-2020-11-05-17-41-01-319.png|width=841,height=318! !image-2020-11-05-17-40-05-630.png|width=955,height=581! {code:java} [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.kafka.common.serialization.ByteArrayDeserializer {code} if i add both jar, it returm exception too {code:java} [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.kafka.common.serialization.ByteArrayDeserializer {code} ddl & sql: {code:java} CREATE TABLE UserBehavior ( user_id BIGINT, item_id BIGINT, behavior CHAR(2), `time` BIGINT ) WITH ( 'connector' = 'kafka', 'topic' = 'user_behavior', 'properties.bootstrap.servers' = 'localhost:9092', 'properties.group.id' = 'user_behavior_flink', 'format' = 'json', 'json.ignore-parse-errors' = 'true', 'scan.startup.mode' = 'earliest-offset', 'scan.topic-partition-discovery.interval' = '10000' ); select * from UserBehavior;{code} -- This message was sent by Atlassian Jira (v8.3.4#803005)