[BEAM-11044] Support worker abort when instructed by the backend

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.26.0
• Component/s: runner-dataflow
• Assignee: Tudor Marian
• Reporter: Tudor Marian
• Created: 08/Oct/20 17:06
• Updated: 15/May/21 18:00
• Resolved: 15/May/21 18:00

Description

The current worker is not handling any abort instructions received.  It should support that, furthermore, it should also be able to stop (abort) in the middle of a stream of values behind the same key.

Issue Links

• links to: GitHub Pull Request #12994