You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 00:05:18 UTC
[jira] [Commented] (BEAM-5) Import Flink Runner code
[ https://issues.apache.org/jira/browse/BEAM-5?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176670#comment-15176670 ]
ASF GitHub Bot commented on BEAM-5:
-----------------------------------
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/12
[BEAM-5] Add Flink Runner
As of [BEAM-5](https://issues.apache.org/jira/browse/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 https://github.com/dataArtisans/flink-dataflow) 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 it.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/incubator-beam master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-beam/pull/12.patch
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 <mx...@apache.org>
Date: 2016-03-01T16:57:02Z
[maven] add project for Runners
commit b64d5a316328e67232b6beca0ed64e362e607ad6
Author: Maximilian Michels <mx...@apache.org>
Date: 2016-03-02T21:58:29Z
[flink-runner] initial code drop
commit 16bb3e66961f56590189a558a75ec34c218f3363
Author: Maximilian Michels <mx...@apache.org>
Date: 2016-03-02T22:03:37Z
[flink-runner] convert tabs to 2 spaces
commit cabb475346c9e94274fa3fe472d3d04b3eb9fd02
Author: Maximilian Michels <mx...@apache.org>
Date: 2016-03-02T22:12:41Z
[flink-runner] change package namespace
commit fe363e565a656011ae74018d5dc700e9665e4033
Author: Maximilian Michels <mx...@apache.org>
Date: 2016-03-02T22:15:22Z
[flink-runner] adjust directories according to package name
commit feeb1f5c80d68b034ac7c2ba70a29af6de28aab8
Author: Maximilian Michels <mx...@apache.org>
Date: 2016-03-02T22:21:57Z
[flink-runner] update license headers
commit 1afe77017c8c7c457c262aa67c8a593d41496b5f
Author: Maximilian Michels <mx...@apache.org>
Date: 2016-03-02T22:51:38Z
[flink-runner] update README
----
> Import Flink Runner code
> ------------------------
>
> Key: BEAM-5
> URL: https://issues.apache.org/jira/browse/BEAM-5
> Project: Beam
> Issue Type: Sub-task
> Components: runner-flink
> Reporter: Frances Perry
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)