【BUG】为什么flink lib目录下的flink-sql-connector-kafka-1.16.1.jar不生效,而需要将jar包放在 apache-streampark_2.12-2.1.2/lib中呢 #3614
Unanswered
t822876884
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
在测试flink sql的过程中,发现需要 添加 flink-sql-connector-kafka-1.16.1.jar ,可以选择页面直接输入pom 或者上传jar包,它是可以运行的;
为了省事,我选择将flink-sql-connector-kafka-1.16.1.jar包放在flink lib目录下,奇怪的是,它并没有生效。
我重新查看了之前在页面配置的任务的flink webui,发现加载了大量的 apache-streampark_2.12-2.1.2/lib 下的jar包,我将 flink-sql-connector-kafka-1.16.1.jar 上传到 lib后,重启了服务,竟然成功了。
问题来了,为什么将jar包放在flink/lib下没有生效呢?
Beta Was this translation helpful? Give feedback.
All reactions