flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7065) separate the flink-streaming-java module from flink-clients
Date Tue, 11 Jul 2017 10:43:02 GMT

    [ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16082022#comment-16082022

ASF GitHub Bot commented on FLINK-7065:

Github user fhueske commented on the issue:

    Hi @XuPingyong, @tillrohrmann is not available for the next two weeks. 

> 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
> 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.

This message was sent by Atlassian JIRA

View raw message