[FLINK-7065] separate the flink-streaming-java module from flink-clients

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: API / DataStream
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: Xu Pingyong
• Created: 03/Jul/17 10:03
• Updated: 01/Jan/22 22:38

Description

Motivation:
It is not good that "flink-streaming-java" module depends on "flink-clients". Flink-clients should see something in "flink-streaming-java".

Related Change:
1. LocalStreamEnvironment and RemoteStreamEnvironment can also execute a job by the executors(LocalExecutor and RemoteExecutor). Introduce StreamGraphExecutor which executors a streamGraph as PlanExecutor executors the plan. StreamGraphExecutor and PlanExecutor all extend Executor.
2. Introduce StreamExecutionEnvironmentFactory which works similarly to ContextEnvironmentFactory in flink-clients.
When a object of ContextEnvironmentFactory, OptimizerPlanEnvironmentFactory or PreviewPlanEnvironmentFactory is set into ExecutionEnvironment(by calling initializeContextEnvironment)， the relevant StreamEnvFactory is alsot set into StreamExecutionEnvironment. It is similar when calling unsetContext.

Issue Links

• links to: GitHub Pull Request #4273
• links to: GitHub Pull Request #4273