Manual checkpoint

[nragon]

Can I trigger a checkpoint based on a specific event?
Meaning, if a given event arrives (containing EOF in this case) it would be
broadcasted to all downstream operators and trigger a savepoint aftewards.

Thanks,
Nuno



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Aljoscha Krettek]

Hi,

Triggering a savepoint is currently not possible from within a job. The job would somehow have to emit a message that an outside system would pick up and then trigger a savepoint.

Best,
Aljoscha

> On 10. Oct 2017, at 17:25, nragon <[hidden email]> wrote:
>
> Can I trigger a checkpoint based on a specific event?
> Meaning, if a given event arrives (containing EOF in this case) it would be
> broadcasted to all downstream operators and trigger a savepoint aftewards.
>
> Thanks,
> Nuno
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Rahul Raj]

You can use FLink's REST API to get the job id of running jobs and then cancel it via CLI commands. You can enclose both things i.e. getting job ids and CLI command in a single script.

Rahul Raj

On 11 October 2017 at 15:47, Aljoscha Krettek <[hidden email]> wrote:

Hi,

Triggering a savepoint is currently not possible from within a job. The job would somehow have to emit a message that an outside system would pick up and then trigger a savepoint.

Best,
Aljoscha

> On 10. Oct 2017, at 17:25, nragon <[hidden email]> wrote:
>
> Can I trigger a checkpoint based on a specific event?
> Meaning, if a given event arrives (containing EOF in this case) it would be
> broadcasted to all downstream operators and trigger a savepoint aftewards.
>
> Thanks,
> Nuno
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/