Thanks that also works. To avoid same issue with zookeeper, I assume I have
to do the same trick?

On Sun, Nov 4, 2018, 03:34 Ufuk Celebi <u...@apache.org> wrote:

> Hey Hao Sun,
>
> this has been changed recently [1] in order to properly support
> failover in job cluster mode.
>
> A workaround for you would be to add an application identifier to the
> checkpoint path of each application, resulting in S3 paths like
> application-XXXX/00...00/chk-64.
>
> Is that a feasible solution?
>
> As a side note: It was considered to keep the job ID fixed, but make
> it configurable (e.g. by providing a --job-id argument) which would
> also help to avoid this situation, but I'm not aware of any concrete
> plans to move forward with that approach.
>
> Best,
>
> Ufuk
>
> [1] https://issues.apache.org/jira/projects/FLINK/issues/FLINK-10291
> <https://issues.apache.org/jira/projects/FLINK/issues/FLINK-10291>
>
> On Sun, Nov 4, 2018 at 3:39 AM Hao Sun <ha...@zendesk.com> wrote:
> >
> > I am wondering if I can customize job_id for job cluster mode. Currently
> it is always 00000000000000000000000000000000. I am running multiple job
> clusters and sharing s3, it means checkpoints will be shared by different
> jobs as well e.g. 00000000000000000000000000000000/chk-64, how can I avoid
> this?
> >
> > Thanks
>

Reply via email to