[
https://issues.apache.org/jira/browse/FLINK-20109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230606#comment-17230606
]
hailong wang commented on FLINK-20109:
--------------------------------------
Hi [~aaronxu], We should use English here for that users from all over the
world can understand it.
For the problem you described.
Do you confirm that which classLoad is this JAR loaded when putting it to
classPath, and which classLoad is this JAR loaded when putting it to lib
directory.
Whether the load order conforms to the Java specification.
> 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
> Priority: Major
>
> 按照官网例子 加载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)
