Versions Compared

Key

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

...

2) Reduce resource usage.  For use-case that involves an operatorA operatorB (with unbounded input) depending on the output of another operatorBoperatorA, where operatorB operatorA only emits results at the end of its input, Flink will deploy operatorB after operatorA is finished. This approach reduces the unnecessary resource usage when operatorA is still processing its inputs.

...