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
