flink1.18.0 sql-client报错

• 大数据

报错

Flink SQL> 
> 
> select * from t1;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.kafka.clients.consumer.OffsetResetStrategy

解决

flink1.18.0 sql-client报错

flink1.18.0 sql-client报错

注意 一定要重启flink服务 否则还会报错: 

Flink SQL> select * from t1;

[ERROR] Could not execute SQL statement. Reason:

java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource

本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://net2asp.com/936e64bb29.html

赞 (0)
« 上一篇 1天前
下一篇 » 1天前

相关推荐