Versions Compared

Old Version 32

changes.mady.by.user Ran Jinhao

Saved on

compared with

New Version 33

changes.mady.by.user Dong Lin

Saved on

Key

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

...

  • The process of operator chain can still be done. After that, the results of its operator chain as well as and its upstream operators will be set blocking (by default) or hybrid shuffle partition type which can be controlled by configuring ExecutionOptions.BATCH_SHUFFLE_MODE.
  • This operator as well as its upstream operators will be executed in batch mode (e.g . More specifically, the checkpoint is disabled when these operators are running ).so that these operators can do things like sorting inputs. And operators should re-read the data from the upstream blocking edge or sources after failover. 


4) A blocking input edge with pending records is same as a source with isBacklog=true when an operator determines its RecordAttributes for downstream nodes.

...