报错
Flink SQL>
>
> select * from t1;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.kafka.clients.consumer.OffsetResetStrategy
解决
注意 一定要重启flink服务 否则还会报错:
Flink SQL> select * from t1;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource
本文转载自: https://blog.csdn.net/qq_35515661/article/details/134312204
版权归原作者 Thomas2143 所有, 如有侵权,请联系我们删除。
版权归原作者 Thomas2143 所有, 如有侵权,请联系我们删除。