Thanks Ufuk. Really appreciated. On Thu, Jun 30, 2016 at 2:07 AM, Ufuk Celebi <u...@apache.org> wrote:
> You are right, this is not very well-documented. You can do it like this: > > > env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.AT_LEAST_ONCE); > > With this the operators don't wait for all barriers to align. Example > for checkpoint mode setting is here: > > https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/fault_tolerance.html > > > On Wed, Jun 29, 2016 at 10:58 PM, Daniel Li <daniell...@gmail.com> wrote: > > I am reading Stream Checkpointing doc below. But somehow couldn't find > that > > "switch" in any other Apache Flink docs. Has anyone of you tried this > > switch? > > > > > > > https://ci.apache.org/projects/flink/flink-docs-master/internals/stream_checkpointing.html > > > > "Flink has a switch to skip the stream alignment during a checkpoint. > > Checkpoint snapshots are still drawn as soon as an operator has seen the > > checkpoint barrier from each input." > > > > > > thx > > Daniel >
