flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tillrohrmann <...@git.apache.org>
Subject [GitHub] flink pull request #4271: [FLINK-7113] Make ClusterDescriptor independent of...
Date Thu, 06 Jul 2017 14:58:50 GMT
GitHub user tillrohrmann opened a pull request:


    [FLINK-7113] Make ClusterDescriptor independent of cluster size

    This PR is based on #4270.
    In order to pull some of the cluster deployment logic out of the `AbstractYarnClusterDescriptor`,
this PR introduces a `ClusterSpecification`. This specification contains information about
the size of the cluster to be started. Instead of setting these values via setters directly
on the `ClusterDescriptor`, we provide the information at deployment time via the `ClusterSpecification`.
    The way I envision the `ClusterDescriptor` to work, is to only contain information which
is necessary to talk to a resource manager, such as Mesos or Yarn. All Flink cluster specific
information should be provided to the `deploy` methods. This also allows us better share code
between different `ClusterDescriptor`, e.g. Mesos and Yarn.
    This is only the start of a refactoring of the `ClusterDescriptor`. Much more information
can be pulled out of the `AbstractYarnClusterDescriptor`.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/tillrohrmann/flink refactorClusterDescriptor

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #4271
commit 9cfb9718d7b64e253aaf636dc17b8939e2592a98
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2017-07-06T07:33:18Z

    [FLINK-7110] [client] Add per-job cluster deployment interface

commit 0143d7e33b7d99ce8371e455458b730ba2c13d06
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2017-07-06T12:00:21Z

    [FLINK-7113] Make ClusterDescriptor independent of cluster size
    The deploySession method now is given a ClusterSpecification which specifies the
    size of the cluster which it is supposed to deploy.


If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message