[FLINK-17673] Add failure reason to OperatorCoordinator.failTask(...)

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Runtime / Coordination
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 13/May/20 14:37
• Updated: 16/May/20 16:37
• Resolved: 16/May/20 16:37

Description

Adding the failure cause (Throwable) to the OperatorCoordinator.failTask() method supports the implementations to do better error reporting and to differentiate between the error causes.