You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Dream-底限 <zh...@akulaku.com> on 2020/07/02 04:09:05 UTC

flink任务提交方式

hi
请问现在flink有没有像sparklauncher这种任务提交方式，在任务提交成功后返回对应的任务id（不管是onyarn还是standlone），我这面想用java代码提交任务并在提交后获取任务id，请问有没有对应功能或工具

Re: flink任务提交方式

Posted by admin <17...@163.com>.

Hi,
1.10.x版本以后env.execute()是返回一个JobExecutionResult
对象的，这里面可以获取到job相关信息,比如你想要的jobid

> 2020年7月2日 下午12:09，Dream-底限 <zh...@akulaku.com> 写道：
> 
> hi
> 请问现在flink有没有像sparklauncher这种任务提交方式，在任务提交成功后返回对应的任务id（不管是onyarn还是standlone），我这面想用java代码提交任务并在提交后获取任务id，请问有没有对应功能或工具

Re: flink任务提交方式

Posted by Dream-底限 <zh...@akulaku.com>.

好的，感谢

On Thu, Jul 2, 2020 at 12:37 PM jianxu <rj...@163.com> wrote:

> 你可以看下这个项目https://github.com/todd5167/clusters-submiter，改造下应该满足你的需求。
> 在 2020-07-02 12:09:05，"Dream-底限" <zh...@akulaku.com> 写道：
> >hi
>
> >请问现在flink有没有像sparklauncher这种任务提交方式，在任务提交成功后返回对应的任务id（不管是onyarn还是standlone），我这面想用java代码提交任务并在提交后获取任务id，请问有没有对应功能或工具
>

Re:flink任务提交方式

Posted by jianxu <rj...@163.com>.

你可以看下这个项目https://github.com/todd5167/clusters-submiter，改造下应该满足你的需求。
在 2020-07-02 12:09:05，"Dream-底限" <zh...@akulaku.com> 写道：
>hi
>请问现在flink有没有像sparklauncher这种任务提交方式，在任务提交成功后返回对应的任务id（不管是onyarn还是standlone），我这面想用java代码提交任务并在提交后获取任务id，请问有没有对应功能或工具