完整报错如下:
select * from dim_behavior;
[ERROR] Could not execute SQL statement. Reason:
java.lang.NoSuchMethodError: org.apache.flink.table.api.TableColumn.isGenerated()Z
经过检查是因为在1.12的Flink的$FLINK_HOME/lib下面使用了1.11版本的flink-connector-clickhouse
这种版本失配直接导致flink无法读取mysql中的内容。
因为1.12中的类加载顺序是不可控的。
所以千万要注意版本,。
解决方案:
在1.12的$FLINK_HOME/lib下面
删除flink-connector-clickhouse的jar