[FLINK-20223] The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader.

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.12.0, 1.11.3
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 18/Nov/20 13:54
• Updated: 12/Dec/20 11:56
• Resolved: 23/Nov/20 11:38

Description

The RecreateOnResetOperatorCoordinator and the SourceCoordinator executor thread should both use the user class loader. Otherwise ClassNotFoundException may be thrown from the interaction with the {{SplitEnumerator}}s.

Issue Links

• blocks: FLINK-20157 SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission
• links to: GitHub Pull Request #14143