Apache Flink中RowData导入无法解析问题求助

你遇到的问题是因为org.apache.flink.table.data.RowData类并不在你当前引入的flink-table-api-java依赖中，需要添加对应的桥接依赖。

解决方案 #

在你的pom.xml中添加以下依赖：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-table-api-java-bridge</artifactId>
    <version>1.19.1</version>
    <!-- 若提交到Flink集群运行，可添加<scope>provided</scope>，本地开发建议移除该配置 -->
</dependency>

原因说明 #

• flink-table-api-java仅包含Table API的核心接口定义，不包含RowData这类用于Table API与DataStream API交互的底层数据结构类。
• flink-table-api-java-bridge是Flink Table API与Java DataStream API的桥接依赖，包含了RowData的完整类定义，能满足你在代码中使用该类的需求。

添加依赖后，执行mvn clean package重新编译，IDE的导入错误也会自动消失。

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