报错
Flink SQL> select * from t1;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.
Available factory identifiers are:
blackhole
datagen
filesystem
print
python-input-format
解决
官网下载这个放到$FLINK_HOME/lib下即可
本文转载自: https://blog.csdn.net/qq_35515661/article/details/134312154
版权归原作者 Thomas2143 所有， 如有侵权，请联系我们删除。
版权归原作者 Thomas2143 所有， 如有侵权，请联系我们删除。