[jira] [Created] (FLINK-20109) java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

[Shang Yuanchun (Jira)]

xuhaoran created FLINK-20109:
--------------------------------

             Summary: java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer
                 Key: FLINK-20109
                 URL: https://issues.apache.org/jira/browse/FLINK-20109
             Project: Flink
          Issue Type: Bug
          Components: Client / Job Submission
    Affects Versions: 1.11.2
         Environment: macos 10.14.6 

flink 1.11.2
            Reporter: xuhaoran


按照官网例子 加载Kafka的连接器需要下载flink-sql-connector-kafka_2.11-1.11.2.jar

然后启动指令为./sql-client.sh embedded -lib xxx/ 

然后创建简单的sql语句 创建 Kafka table 

执行都ok

 

但如果flink-sql-connector-kafka_2.11-1.11.2.jar 放在classpath里面  启动./sql-client.sh embedded ps -ef|grep java 也可以看到当前classpath加载了flink-sql-connector-kafka_2.11-1.11.2.jar

执行之前的创建kafka table 执行select * from table 

报错java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

怀疑类加载器有问题

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)