beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <>
Subject [jira] [Commented] (BEAM-5) Import Flink Runner code
Date Wed, 02 Mar 2016 23:05:18 GMT


ASF GitHub Bot commented on BEAM-5:

GitHub user mxm opened a pull request:

    [BEAM-5] Add Flink Runner

    As of [BEAM-5]( and the previous mailing
list discussion, I would like to contribute the Flink Runner to Beam.
    According to the repository layout document, I have created a Beam Runners project which
will host the runners. Therein, I have added the Flink runner with a few modifications mostly
related to code formatting and licensing. These changes you can see in the individual commits.
Note, that everything builds and the tests run fine.
    The Runner is in sync with the latest Beam SDK version which is currently 1.5.0-SNAPSHOT.
I would like to point out that the runner also supports the stable 1.0.0 version (in the 1.0.0
branch at but I've added the latest version
here to keep up with the latest changes in Beam.
    Please let me know what you think about the pull request and when you would like to merge

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

    $ git pull master

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 #12
commit 2d67aa0b17ee67915e1c4d18e61ce27a2b8d9535
Author: Maximilian Michels <>
Date:   2016-03-01T16:57:02Z

    [maven] add project for Runners

commit b64d5a316328e67232b6beca0ed64e362e607ad6
Author: Maximilian Michels <>
Date:   2016-03-02T21:58:29Z

    [flink-runner] initial code drop

commit 16bb3e66961f56590189a558a75ec34c218f3363
Author: Maximilian Michels <>
Date:   2016-03-02T22:03:37Z

    [flink-runner] convert tabs to 2 spaces

commit cabb475346c9e94274fa3fe472d3d04b3eb9fd02
Author: Maximilian Michels <>
Date:   2016-03-02T22:12:41Z

    [flink-runner] change package namespace

commit fe363e565a656011ae74018d5dc700e9665e4033
Author: Maximilian Michels <>
Date:   2016-03-02T22:15:22Z

    [flink-runner] adjust directories according to package name

commit feeb1f5c80d68b034ac7c2ba70a29af6de28aab8
Author: Maximilian Michels <>
Date:   2016-03-02T22:21:57Z

    [flink-runner] update license headers

commit 1afe77017c8c7c457c262aa67c8a593d41496b5f
Author: Maximilian Michels <>
Date:   2016-03-02T22:51:38Z

    [flink-runner] update README


> Import Flink Runner code
> ------------------------
>                 Key: BEAM-5
>                 URL:
>             Project: Beam
>          Issue Type: Sub-task
>          Components: runner-flink
>            Reporter: Frances Perry

This message was sent by Atlassian JIRA

View raw message