You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Marek Svitok <ma...@gmail.com> on 2016/09/08 15:25:58 UTC

Administration of running jobs

Hi all.

I'm pretty new to Apache Flink. I'd like to ask you how we can manage 
running jobs. I've noticed one possibility
using UI running on 8081 by default, but I'm aiming to some java API. My 
problem is that I should be able
to dynamically add and remove jobs which are CEP rules because this 
rules could be changed at runtime.

Thank you,
Marek Svitok

Re: Administration of running jobs

Posted by Marek Svitok <ma...@gmail.com>.
Hi Robert.

Thank you very much for your reply. I'll take a look at it.

Marek.

On 9.9.2016 12:09, Robert Metzger wrote:
> Hi Marek,
>
> You can use the RemoteExecutionEnvironment to submit a job 
> programatically to a Flink cluster.
>
> there is also some ongoing work to programatically control submitted 
> jobs: https://issues.apache.org/jira/browse/FLINK-4272. But for now 
> you would probably need to hack something using the JobManager's REST 
> APIs.
>
> Regards,
> Robert
>
>
> On Thu, Sep 8, 2016 at 5:25 PM, Marek Svitok <marek.svitok@gmail.com 
> <ma...@gmail.com>> wrote:
>
>     Hi all.
>
>     I'm pretty new to Apache Flink. I'd like to ask you how we can
>     manage running jobs. I've noticed one possibility
>     using UI running on 8081 by default, but I'm aiming to some java
>     API. My problem is that I should be able
>     to dynamically add and remove jobs which are CEP rules because
>     this rules could be changed at runtime.
>
>     Thank you,
>     Marek Svitok
>
>

Re: Administration of running jobs

Posted by Robert Metzger <rm...@apache.org>.
Hi Marek,

You can use the RemoteExecutionEnvironment to submit a job programatically
to a Flink cluster.

there is also some ongoing work to programatically control submitted jobs:
https://issues.apache.org/jira/browse/FLINK-4272. But for now you would
probably need to hack something using the JobManager's REST APIs.

Regards,
Robert


On Thu, Sep 8, 2016 at 5:25 PM, Marek Svitok <ma...@gmail.com> wrote:

> Hi all.
>
> I'm pretty new to Apache Flink. I'd like to ask you how we can manage
> running jobs. I've noticed one possibility
> using UI running on 8081 by default, but I'm aiming to some java API. My
> problem is that I should be able
> to dynamically add and remove jobs which are CEP rules because this rules
> could be changed at runtime.
>
> Thank you,
> Marek Svitok
>