赞
踩
今天起动flink ./sql-client.sh 异常如下
./sql-client.sh embedded No default environment specified. Searching for '/data/flink-1.11.2/conf/sql-client-defaults.yaml'...found. Reading default environment from: file:/data/flink-1.11.2/conf/sql-client-defaults.yaml No session environment specified. Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue. at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213) Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could not create execution context. at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:870) at org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227) at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108) at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201) Caused by: java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase at java.lang.ClassLoader.defineClass1(Native Method) at java.lang.ClassLoader.defineClass(ClassLoader.java:756) at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
无脑百度半小时才找到一位大佬的解决办法,我自己也记下笔记
2、去如下地址下载
https://nightlies.apache.org/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html
3、截图如下,下载好
4、删掉原来目录下kafka包
# 进入到目录(你自己安装的flink) flink/lib/
rm -rf flink-connector-kafka_2.12-1.11.2.jar
5、上传下载好的包到 flink/lib
6、启动成功
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。