Hi, Buvana, Please see answers below.
On Tue, Jul 5, 2016 at 11:47 AM, Ramanan, Buvana (Nokia - US) < buvana.rama...@nokia-bell-labs.com> wrote: > > Does this mean that all writes to the disk for state store purposes will > be done at the checkpointing time (which is also the time Samza checkpoints > the incoming stream offsets)? Does this also mean new data to the changelog > stream will be emitted at checkpointing time? > > Yes, the commit workflow in Samza guarantees that a) pending writes to on-disk KV-stores are flushed; b) all pending writes to output streams are flushed, including the writes to changelog streams; c) all input offsets are flushed to checkpoint. Hope the above answers your questions. -Yi
