Flink 1.5.0-SNAPSHOT RestClient响应异常：Spring Boot启动方式差异故障

我之前也碰到过一模一样的场景：直接跑主类能正常提交Flink作业，用Maven命令启动就触发RestClient异常。核心问题出在两种启动方式的类加载逻辑和环境参数传递差异上，给你几个靠谱的排查和解决方向：

1. 先排查类路径依赖冲突 #

mvn spring-boot:run会触发Maven的依赖聚合逻辑，很可能引入了和Flink不兼容的依赖（比如Jackson、Netty这类Flink核心依赖），而IDE直接跑主类时类路径更干净。

• 第一步，用mvn dependency:tree打印依赖树，搜索flink-rest、jackson-databind、netty这些关键字，看是否有版本不一致的情况。
• 比如我当时的问题是Spring Boot自带的Jackson版本比Flink依赖的高2个大版本，导致RestClient解析响应时序列化失败。解决办法是排除Spring Boot的Jackson依赖，统一用Flink兼容的版本：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <exclusions>
        <exclusion>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<!-- 替换成和你Flink版本匹配的Jackson版本，比如Flink 1.13对应Jackson 2.11.x -->
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.11.4</version>
</dependency>

2. 确保Flink所需的系统参数被正确传递 #

IDE跑主类时，你可能在运行配置里加了Flink相关的系统参数（比如-Dflink.rest.address、-Dflink.rest.port），但mvn spring-boot:run默认不会继承这些参数。

• 临时测试可以直接在命令行传递：

mvn spring-boot:run -Dflink.rest.address=你的Flink集群Rest地址 -Dflink.rest.port=8081

• 要永久生效的话，修改pom.xml里的Spring Boot插件配置：

<plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
    <configuration>
        <systemProperties>
            <systemProperty>
                <key>flink.rest.address</key>
                <value>你的Flink集群Rest地址</value>
            </systemProperty>
            <systemProperty>
                <key>flink.rest.port</key>
                <value>8081</value>
            </systemProperty>
            <!-- 要是有网络代理、SSL相关参数也可以在这加 -->
        </systemProperties>
    </configuration>
</plugin>

3. 调整Spring Boot的类加载策略 #

Spring Boot的Maven插件默认用LaunchedURLClassLoader，这个类加载器的逻辑和普通Java主类启动不一样，可能和Flink的类加载机制冲突。

可以尝试修改插件配置，切换回传统的类加载方式：

<plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
    <configuration>
        <useMainClassManifest>true</useMainClassManifest>
        <layout>JAR</layout> <!-- 如果你是WAR包就改成WAR -->
    </configuration>
</plugin>

额外排查小技巧 #

• 开启Flink RestClient的Debug日志，看具体请求和响应内容：在你的日志配置文件（比如logback.xml）里加这两行，能帮你定位是请求发错了还是响应解析失败：

<logger name="org.apache.flink.runtime.rest" level="DEBUG"/>
<logger name="org.apache.flink.shaded.netty" level="DEBUG"/>

• 检查CentOS的防火墙：有时候IDE进程有特殊网络权限，而Maven启动的进程被防火墙挡住了，没法访问Flink的8081端口，用telnet 你的Flink地址 8081测试下连通性。

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