It has not changed the operator execution model. State serialization is still synchronous, write to HDFS is taken out of the operator thread.
On Tue, Sep 15, 2015 at 8:18 AM, Amol Kekre <[email protected]> wrote: > > Sent too soon. Has asynchronous checkpointing changed this? > > Amol > > Sent from my iPhone > > > On Sep 15, 2015, at 12:38 AM, Bhupesh Chawda <[email protected]> > wrote: > > > > Hi All, > > > > Is it safe to assume that the checkpointed() and the beginWindow() calls > > are sequenced? > > In other words, are these calls part of the same thread and may not run > in > > parallel? > > > > Thanks. > > > > -- > > -Bhupesh >
