如果是通过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/
