会话模式Flink集群提交Detached作业后CLI阻塞不返回

核心原因 #

你遇到的CLI阻塞问题，根源在作业代码中的两个阻塞调用——即使使用--detached参数提交，客户端仍会等待这些调用的执行结果，导致无法正常返回：

1. sinkResult.print()：TableResult.print()方法会阻塞客户端，持续等待作业的输出日志/结果，直到作业终止。在Detached模式下，客户端本应提交作业后立即断开连接，无需等待作业运行。
2. env.execute("test job")：通过tableEnvironment.executeSql("insert...")已经触发了作业提交，重复调用env.execute()会让客户端等待另一个作业的执行完成，进一步加剧阻塞。

修正后的代码 #

移除上述两个阻塞调用，修改后的代码如下：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tableEnvironment = StreamTableEnvironment.create(env, streamSettings);
tableEnvironment.executeSql("create TEMPORARY table source_table ....");
tableEnvironment.executeSql("create TEMPORARY table redis_sink ....");
// 仅提交insert作业，不等待输出或重复执行
tableEnvironment.executeSql("insert into redis_sink select * from source_table");

额外验证点 #

1. 确认提交命令的--detached参数位置正确：你的命令中--detached放在run之后，参数顺序正确，无需调整。
2. 检查Flink集群配置：确保jobmanager.rpc.address和jobmanager.host配置正确，客户端能正常与JobManager通信并完成提交。

修改代码后重新提交作业，CLI会在输出Job ID后立即返回，满足CI流水线的需求。

内容的提问来源于stack exchange，提问作者万年水母