使用ParquetAvroInputFormat读Parquet文件时遇LogicalTypeRoot类找不到错误求助

核心原因 #

org.apache.flink.table.types.logical.LogicalTypeRoot类属于flink-table-common依赖，仅引入flink-table-api-scala-bridge可能未自动传递引入该依赖，或是依赖版本不匹配、范围设置不当，导致编译或运行时无法找到目标类。

具体解决建议 #

1. 显式引入flink-table-common依赖 #

在Scala项目的构建文件（如sbt的build.sbt或Maven的pom.xml）中，直接添加flink-table-common依赖，必须保证版本与已引入的Flink其他依赖（包括table bridge）完全一致：

sbt示例：

libraryDependencies += "org.apache.flink" %% "flink-table-common" % "你的Flink版本号" % "compile"

Maven示例：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-table-common</artifactId>
    <version>你的Flink版本号</version>
    <scope>compile</scope>
</dependency>

2. 检查依赖范围设置 #

确保flink-table-common和flink-table-api-scala-bridge的依赖范围不是provided（除非你在已预装该依赖的Flink集群环境运行），否则打包时不会将依赖打入Jar包，运行时会出现类缺失问题。

3. 验证依赖传递与版本一致性 #

• 用构建工具的依赖分析命令检查依赖树，确认flink-table-common是否被正确引入且无版本冲突：
  • sbt：执行 sbt dependencyTree
  • Maven：执行 mvn dependency:tree
• 若存在版本冲突，需排除冲突依赖，强制指定正确的Flink版本。

4. 清理并重新构建项目 #

• 清理本地构建缓存：
  • sbt：sbt clean
  • Maven：mvn clean
• 重新编译打包：
  • sbt：sbt compile package
  • Maven：mvn compile package

5. 检查IDE运行环境的类路径 #

如果在本地IDE运行，确认IDE的项目依赖中已包含flink-table-common，可通过IDE的依赖管理界面（如IntelliJ的Project Structure）查看并刷新依赖。

内容的提问来源于stack exchange，提问作者None