[FLINK-13954] Clean up ExecutionEnvironment / JobSubmission code paths

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.9.0
• Component/s: Client / Job Submission
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
• Assignee: Unassigned
• Reporter: Kostas Kloudas
• Created: 04/Sep/19 09:49
• Updated: 20/Dec/21 22:38

Description

This is an umbrella issue to serve as a hub for all issues related to job submission / (stream) execution environment refactoring.

 

This issue does not change any existing functionality, but it targets to clean up / rearrange the code in the relevant components so that further changes are easier to apply.

Sub-Tasks

• Remove deactivated JobSession-related code.: Closed
• Consolidate DetachedEnvironment and ContextEnvironment: Closed
• Remove obsolete abstraction JobExecutor(Service): Closed
• Move PreviewPlanEnvironment to flink-tests: Closed
• Refactor YarnClusterDescriptor inheritance: Closed
• Deploy job cluster in attached mode: Reopened
• Decouple PlanExecutor from JSON plan generation: Closed
• Merge NewClusterClient into ClusterClient: Closed
• Remove class JobWithJars: Resolved
• Shift down ClusterClient#timeout to RestClusterClient: Resolved
• Remove ClusterClient.run() methods: Closed
• Introduce separate "bin/flink runpy" and remove python support from "bin/flink run": Open
• Extract static method from ClusterClient to ClientUtils: Closed
• Decouple plan translation from job execution/ClusterClient: Closed
• Remove FlinkPlan Interface: Closed
• YarnClusterDescriptor should not know about detached option: Closed
• Remove PlanExposingEnvironment: Closed