Ok, thanks for the clarification. On Thu, Dec 28, 2017 at 1:05 AM Ufuk Celebi <u...@apache.org> wrote:
> On Thu, Dec 28, 2017 at 12:11 AM, Hao Sun <ha...@zendesk.com> wrote: > > Thanks! Great to know I do not have to worry duplicates inside Flink. > > > > One more question, why this happens? Because TM and JM both check > leadership > > in different interval? > > Yes, it's not deterministic how this happens. There will also be cases > when the JM notices before the TM. > >
