flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Xu Pingyong (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7065) separate the flink-streaming-java module from flink-clients
Date Mon, 03 Jul 2017 10:04:00 GMT
Xu Pingyong created FLINK-7065:

             Summary: separate the flink-streaming-java module from flink-clients 
                 Key: FLINK-7065
                 URL: https://issues.apache.org/jira/browse/FLINK-7065
             Project: Flink
          Issue Type: Improvement
          Components: DataStream API
            Reporter: Xu Pingyong
            Assignee: Xu Pingyong

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

Proposed Change:
      1. LocalStreamEnvironment and RemoteStreamEnvironment can also execute a job by the
executors(LocalExecutor and RemoteExecutor). 
      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

This message was sent by Atlassian JIRA

View raw message