Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

For simplicity, we assume the Flink job uses default configuration values for all configurations (e.g. scheduler-mode) except execution.runtime-mode. And the operator reads records from a source which switches from isBacklog=true to isBacklog=false before it reaches EOF.


TODO: we will update the FLIP to clarify what happens when isBacklog switches from false to true.


1) Scheduling strategy

Batch mode:

...