[FLINK-14758] Add Executor-related interfaces and utilities

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.0
• Component/s: Client / Job Submission
• Labels: pull-request-available
• Assignee: Kostas Kloudas
• Reporter: Kostas Kloudas
• Created: 13/Nov/19 20:04
• Updated: 14/Nov/19 14:23
• Resolved: 14/Nov/19 14:23

Description

This is issue only targets at introducing the interfaces without (yet) using them. It will add the Executor interface, the ExecutorFactory and the ExecutorServiceLoader which will be able to "discover" the registered ExecutorFactories.

In addition, it will add the env.execute() (both batch and streaming) implementations as described in [FLIP-73|https://cwiki.apache.org/confluence/display/FLINK/FLIP-73%3A+Introducing+Executors+for+job+submission], but this is not going to affect anything as the current environments override the execute() method.

Issue Links

• links to: GitHub Pull Request #10194