[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765799#comment-15765799 ]
ASF GitHub Bot commented on BEAM-79: ------------------------------------ GitHub user manuzhang reopened a pull request: https://github.com/apache/incubator-beam/pull/1663 [BEAM-79] merge master into gearpump-runner branch Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is formatted like: `[BEAM-<Jira issue #>] Description of pull request` - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable Travis-CI on your fork and ensure the whole test matrix passes). - [x] Replace `<Jira issue #>` in the title with the actual Jira issue number, if there is one. - [x] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.txt). --- You can merge this pull request into a Git repository by running: $ git pull https://github.com/manuzhang/incubator-beam gearpump-runner-sync Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-beam/pull/1663.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 #1663 ---- commit e9f254ef2769a082c7fbb500c1c28c6224ac5a7f Author: Jakob Homan <jgho...@gmail.com> Date: 2016-12-07T00:59:50Z [BEAM-1099] Minor typos in KafkaIO commit afedd68e806830549724dfc0f2565d756cc6b46d Author: Davor Bonaci <da...@google.com> Date: 2016-12-07T01:03:54Z This closes #1524 commit e8c9686a2e898d38afd692328eb171c542084747 Author: Pei He <pe...@google.com> Date: 2016-11-23T23:59:56Z [BEAM-1047] Add DataflowClient wrapper on top of JSON library. commit ded58832ceaef487f4590d9396f09744288c955d Author: Pei He <pe...@google.com> Date: 2016-11-24T00:14:27Z [Code Health] Remove redundant projectId from DataflowPipelineJob. commit ce03f30c1ee0b84ad2e7f10a6272ffb25548244a Author: Pei He <pe...@google.com> Date: 2016-11-28T19:47:42Z [BEAM-1047] Update dataflow runner code to use DataflowClient wrapper. commit b2b570f27808b1671bf6cd0fc60f874da671d4ca Author: bchambers <bchamb...@google.com> Date: 2016-12-07T01:08:13Z Closes #1434 commit 0a2ed832ce5af7556db605e99b985ed4ffc1b152 Author: Sam McVeety <s...@google.com> Date: 2016-10-30T18:58:44Z BigQueryIO.Read: support runtime options commit 869b2710efdb90bc3ce5b6e9d4f3b49a3a804a63 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2016-12-07T05:28:13Z [FLINK-1102] Fix Aggregator Registration in Flink Batch Runner commit b41a46e86fd38c4a887f31bdf6cb75969f4750d3 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2016-12-07T07:26:02Z This closes #1530 commit baf5e6bd9b1011f4c5c3974aa46393471b340c15 Author: Jean-Baptiste Onofré <jbono...@apache.org> Date: 2016-12-07T07:37:33Z [BEAM-1094] Set test scope for Kafka IO and junit commit 9ccf6dbea0d3807fef6a7c0432906fffd2b8ec3f Author: Sela <ans...@paypal.com> Date: 2016-12-07T08:31:38Z This closes #1531 commit dce3a196a3a26fdd42225520faf3d9084ee48123 Author: Sela <ans...@paypal.com> Date: 2016-12-07T09:20:07Z [BEAM-329] Update Spark runner README. commit 02bb8c375c48847b1686d70184fb194500a62e8c Author: Jean-Baptiste Onofré <jbono...@apache.org> Date: 2016-12-07T11:51:09Z [BEAM-329] This closes #1532 commit b2d72237b592e1dcb5cca30f5cbc9a11d2890c0f Author: Kenneth Knowles <k...@google.com> Date: 2016-12-06T23:20:28Z Port most of DoFnRunner Javadoc to new DoFn commit 1526184ae8be1f8ae6863f830653204157a584cd Author: Thomas Groh <tg...@google.com> Date: 2016-12-07T16:51:02Z This closes #1527 commit 8e1e46e73edf9cce376ed7bd194db00edc3e60b4 Author: Kenneth Knowles <k...@google.com> Date: 2016-12-07T05:01:37Z Port ParDoTest from OldDoFn to new DoFn commit ae52ec1bc3f3120e9f8e150e50c18564055a467c Author: Kenneth Knowles <k...@google.com> Date: 2016-12-07T17:00:18Z This closes #1529 commit 55d333bff68809ff1a9154491ace02d2d16e3b85 Author: Thomas Groh <tg...@google.com> Date: 2016-12-05T22:29:05Z Only provide expanded Inputs and Outputs This removes PInput and POutput from the immediate API Surface of TransformHierarchy.Node, and forces Pipeline Visitors to access only the expanded version of the output. This is part of the move towards the runner-agnostic representation of a graph. commit 5b31a369962907e257de8019fbf6cde4c615b1c0 Author: Thomas Groh <tg...@google.com> Date: 2016-12-07T17:14:38Z This closes #1511 commit 43fef2775145f67def3ab8a246ecca192a7d650b Author: Dan Halperin <dhalp...@google.com> Date: 2016-12-07T12:06:57Z [BEAM-905] Add shading config to examples archetype and enable it for Flink This makes the Flink quickstart work out of the box. commit b44a7ac4a2a0ac9fd7a8e38cc5eea5073c629085 Author: Dan Halperin <dhalp...@google.com> Date: 2016-12-07T22:55:03Z Closes #1533 commit 6439f701d1008d6a0432828e11e0fcc8a4fe6ecc Author: Dan Halperin <dhalp...@google.com> Date: 2016-12-07T23:40:58Z [BEAM-1108] DataflowRunner: remove deprecated TEARDOWN_POLICY control commit 3b2e0290ddbedd199926a70f36c02ea4515841cb Author: Dan Halperin <dhalp...@google.com> Date: 2016-12-08T01:18:11Z Closes #1546 commit 1b1252074dd6b57f4fb88ceb82c704d3d3d8147f Author: Alexey Diomin <diomi...@gmail.com> Date: 2016-12-07T05:39:27Z [BEAM-1095] Add support set config for reuse-object on flink commit c53e0b1623e3ee3c08c329e2716440f031681591 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2016-12-08T01:44:07Z This closes #1518 commit f1a5704a505b01d7d4649b61d1f6697859367964 Author: Alexey Diomin <diomi...@gmail.com> Date: 2016-12-07T05:48:35Z [BEAM-1096] Flink streaming side output optimization using SplitStream commit 6807480a97f2315b3f48ad8dd5accb4e30475fa4 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2016-12-08T01:55:32Z This closes #1520 commit 3f8c80769a3bb38da64c6628fd8c4669fcac794b Author: Kenneth Knowles <k...@google.com> Date: 2016-12-07T04:10:06Z Add DoFn.OnTimerContext commit 2883062eebe8dba849ab89627f6aeb53266ac1a8 Author: Kenneth Knowles <k...@google.com> Date: 2016-12-07T04:10:21Z Access to OnTimerContext via DoFnInvokers.ArgumentProvider commit 42b506f06dbd73e03a2cfad4e7677e9698b3c020 Author: Kenneth Knowles <k...@google.com> Date: 2016-12-07T04:18:18Z Add OnTimerContext parameter support to DoFnSignature ---- > Gearpump runner > --------------- > > Key: BEAM-79 > URL: https://issues.apache.org/jira/browse/BEAM-79 > Project: Beam > Issue Type: New Feature > Components: runner-gearpump > Reporter: Tyler Akidau > Assignee: Manu Zhang > > Intel is submitting Gearpump (http://www.gearpump.io) to ASF > (https://wiki.apache.org/incubator/GearpumpProposal). Appears to be a mix of > low-level primitives a la MillWheel, with some higher level primitives like > non-merging windowing mixed in. Seems like it would make a nice Beam runner. -- This message was sent by Atlassian JIRA (v6.3.4#6332)