Versions Compared

Old Version 40

changes.mady.by.user Yuan Mei

Saved on

compared with

New Version 41

changes.mady.by.user Yuan Mei

Saved on

Key

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

...

In the sink failure case, only the sink vertex is expected to restart. The proposed changes are to extend RestartPipelinedRegionFailoverStrategy to restart a task if the task does not have any consumers. If a non-sink vertex fails, a regional failover strategy takes place. . Notice that RestartPipelinedRegionFailoverStrategy is untouched. The new strategy extends RestartPipelinedRegionFailoverStrategy, reuses most of the logic, and only overrides getTasksNeedingRestart.

...