全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

Flinksql中运行的时候报错，提示：NoSuchMethodError: org.apache.flink.table.types.logical.utils.LogicalTypeChecks.

提问者：帅平问题分类：大数据

Flinksql中运行的时候报错，提示：

Caused by: java.lang.NoSuchMethodError: org.apache.flink.table.types.logical.utils.LogicalTypeChecks.hasRoot(Lorg/apache/flink/table/types/logical/LogicalType;Lorg/apache/flink/table/types/logical/LogicalTypeRoot;)Z
	at org.apache.flink.streaming.connectors.kafka.table.KafkaConnectorOptionsUtil.createKeyFormatProjection(KafkaConnectorOptionsUtil.java:415)
	at org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableFactory.createDynamicTableSource(KafkaDynamicTableFactory.java:181)
	at org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:164)
	... 111 more

Flink版本是1.17，我看了下这个类是flink table api的类，这个flink1.17版本的这个类里面没有hasroot这个方法。这个怎么搞啊？

Flink FlinkSql

发布于：2年前 (2023-07-29) IP属地：四川省

1 个回答

白鸥掠海

这是因为flink-kafka的包版本引入错了，flink1.7的版本需要引入的包是：

flink-sql-connector-kafka-1.17.1.jar

这个包的下载地址是：

https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka/1.17.1/flink-sql-connector-kafka-1.17.1.jar

发布于：2年前 (2023-07-29) IP属地：四川省

我来回答