如果是通过TableEnvironment#execute方法提交需要设置execution.attached=true, 或者是通过flink
cli的 加上-d
如果是通过TableEnvironment#executeSql方法提交,需要代码里显示的等待作业结束:
TableResult tableResult = tEnv.executeSql(xxx);
// wait job finished
tableResult.getJobClient().get().getJobExecutionResult(Thread.currentThread().getContextClassLoader()).get();

lijufeng2016 <[email protected]> 于2020年8月25日周二 上午9:34写道:

> flink1.11 sql api使用per
> job模式提交后,客户端退出,程序在yarn正常运行,客户端与yarn断开连接,与有没有办法不让客户端断开?
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复