[BEAM-12780] StreamingDataflowWorker should limit local retries

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.32.0
• Component/s: runner-dataflow
• Assignee: Sam Whittle
• Reporter: Sam Whittle
• Created: 20/Aug/21 12:06
• Updated: 23/Aug/21 08:23
• Resolved: 23/Aug/21 08:23

Description

Local retries are performed for most user exceptions

This causes things to get stuck unnecessarily if the work item itself was somehow corrupted additionally such processing may no longer be relevant on the worker and should be given up after a while.

Issue Links

• links to: GitHub Pull Request #15360