[FLINK-11103] Set a default uncaught exception handler

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.13.0
• Fix Version/s: 1.14.0
• Component/s: Runtime / Coordination
• Labels: auto-deprioritized-major auto-unassigned pull-request-available starter usability
• Assignee: Ashwin Kolhatkar
• Reporter: Nico Kruber
• Created: 07/Dec/18 13:34
• Updated: 23/Sep/21 18:01
• Resolved: 12/Jul/21 14:45

Description

We should set a default uncaught exception handler in Flink via Thread.setDefaultUncaughtExceptionHandler() which at least logs the exceptions. Ideally, we would even fail the job (could make this configurable) but users may have some ill-behaving threads, e.g. through libraries, which they would want to tolerate and we don't want to change behaviour now.

(FLINK-5232 added this for the JobManager, we need it for the TaskManager)

Issue Links

• is related to: FLINK-16510 Task manager safeguard shutdown may not be reliable
• links to: GitHub Pull Request #15938