Re: flink任务提交方式
Hi, 1.10.x版本以后env.execute()是返回一个JobExecutionResult 对象的,这里面可以获取到job相关信息,比如你想要的jobid > 2020年7月2日 下午12:09,Dream-底限 写道: > > hi > 请问现在flink有没有像sparklauncher这种任务提交方式,在任务提交成功后返回对应的任务id(不管是onyarn还是standlone),我这面想用java代码提交任务并在提交后获取任务id,请问有没有对应功能或工具
Re: flink任务提交方式
好的,感谢 On Thu, Jul 2, 2020 at 12:37 PM jianxu wrote: > 你可以看下这个项目https://github.com/todd5167/clusters-submiter,改造下应该满足你的需求。 > 在 2020-07-02 12:09:05,"Dream-底限" 写道: > >hi > > >请问现在flink有没有像sparklauncher这种任务提交方式,在任务提交成功后返回对应的任务id(不管是onyarn还是standlone),我这面想用java代码提交任务并在提交后获取任务id,请问有没有对应功能或工具 >
flink任务提交方式
hi 请问现在flink有没有像sparklauncher这种任务提交方式,在任务提交成功后返回对应的任务id(不管是onyarn还是standlone),我这面想用java代码提交任务并在提交后获取任务id,请问有没有对应功能或工具