Flink 1.13中使用StatementSet.execute时Listener未触发onJobExecuted问题

针对你遇到的Flink 1.13中onJobExecuted方法未触发的问题，核心原因通常和作业终止时机、客户端监听逻辑有关，以下是具体排查点和解决方法：

1. 调整重启策略，避免作业进入重启循环 #

你测试的字符串转int类型错误属于运行时反序列化异常，Flink默认重启策略（如固定延迟重启）会尝试多次重启Task，此时作业会处于RESTARTING状态，只有当重启次数耗尽后，作业才会进入FAILED终态，onJobExecuted才会被触发。

解决方法：

• 在代码中直接设置无重启策略：

  StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  env.setRestartStrategy(RestartStrategies.noRestart());
  

• 或者在flink-conf.yaml中全局配置：

  restart-strategy: none
  

2. 确保客户端等待作业完成，不提前退出 #

StatementSet.execute()返回的TableResult默认不会强制阻塞客户端进程，若提交作业后客户端代码直接结束，监听器将无法接收后续的作业失败通知。

解决方法：
提交作业后调用await()方法阻塞客户端，直到作业终止：

StatementSet stmtSet = tableEnv.createStatementSet();
// 添加你的SQL语句
TableResult result = stmtSet.execute();
// 阻塞等待作业完成
result.await();

3. 验证监听器实现逻辑 #

检查你的JobListener实现中，onJobExecuted方法是否存在异常捕获逻辑，导致方法执行被静默吞掉。建议在方法中添加日志输出，确认方法是否被调用：

@Override
public void onJobExecuted(JobExecutionResult result, Throwable throwable) {
    if (throwable != null) {
        LOG.error("作业执行失败", throwable);
    } else {
        LOG.info("作业执行完成，结果: {}", result);
    }
}

4. 确认作业最终状态 #

通过Flink Web UI查看作业的最终状态：

• 如果作业一直处于RESTARTING状态：说明重启策略未调整，作业未进入终态，onJobExecuted不会触发
• 如果作业已处于FAILED状态但方法仍未触发：检查客户端是否保持连接，以及监听器是否正确注册到StreamExecutionEnvironment

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