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-79) Gearpump runner
Date Wed, 21 Dec 2016 01:34:58 GMT


ASF GitHub Bot commented on BEAM-79:

GitHub user manuzhang reopened a pull request:

    [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](

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

    $ git pull gearpump-runner-sync

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 #1663
commit e9f254ef2769a082c7fbb500c1c28c6224ac5a7f
Author: Jakob Homan <>
Date:   2016-12-07T00:59:50Z

    [BEAM-1099] Minor typos in KafkaIO

commit afedd68e806830549724dfc0f2565d756cc6b46d
Author: Davor Bonaci <>
Date:   2016-12-07T01:03:54Z

    This closes #1524

commit e8c9686a2e898d38afd692328eb171c542084747
Author: Pei He <>
Date:   2016-11-23T23:59:56Z

    [BEAM-1047] Add DataflowClient wrapper on top of JSON library.

commit ded58832ceaef487f4590d9396f09744288c955d
Author: Pei He <>
Date:   2016-11-24T00:14:27Z

    [Code Health] Remove redundant projectId from DataflowPipelineJob.

commit ce03f30c1ee0b84ad2e7f10a6272ffb25548244a
Author: Pei He <>
Date:   2016-11-28T19:47:42Z

    [BEAM-1047] Update dataflow runner code to use DataflowClient wrapper.

commit b2b570f27808b1671bf6cd0fc60f874da671d4ca
Author: bchambers <>
Date:   2016-12-07T01:08:13Z

    Closes #1434

commit 0a2ed832ce5af7556db605e99b985ed4ffc1b152
Author: Sam McVeety <>
Date:   2016-10-30T18:58:44Z

    BigQueryIO.Read: support runtime options

commit 869b2710efdb90bc3ce5b6e9d4f3b49a3a804a63
Author: Aljoscha Krettek <>
Date:   2016-12-07T05:28:13Z

    [FLINK-1102] Fix Aggregator Registration in Flink Batch Runner

commit b41a46e86fd38c4a887f31bdf6cb75969f4750d3
Author: Aljoscha Krettek <>
Date:   2016-12-07T07:26:02Z

    This closes #1530

commit baf5e6bd9b1011f4c5c3974aa46393471b340c15
Author: Jean-Baptiste Onofré <>
Date:   2016-12-07T07:37:33Z

    [BEAM-1094] Set test scope for Kafka IO and junit

commit 9ccf6dbea0d3807fef6a7c0432906fffd2b8ec3f
Author: Sela <>
Date:   2016-12-07T08:31:38Z

    This closes #1531

commit dce3a196a3a26fdd42225520faf3d9084ee48123
Author: Sela <>
Date:   2016-12-07T09:20:07Z

    [BEAM-329] Update Spark runner README.

commit 02bb8c375c48847b1686d70184fb194500a62e8c
Author: Jean-Baptiste Onofré <>
Date:   2016-12-07T11:51:09Z

    [BEAM-329] This closes #1532

commit b2d72237b592e1dcb5cca30f5cbc9a11d2890c0f
Author: Kenneth Knowles <>
Date:   2016-12-06T23:20:28Z

    Port most of DoFnRunner Javadoc to new DoFn

commit 1526184ae8be1f8ae6863f830653204157a584cd
Author: Thomas Groh <>
Date:   2016-12-07T16:51:02Z

    This closes #1527

commit 8e1e46e73edf9cce376ed7bd194db00edc3e60b4
Author: Kenneth Knowles <>
Date:   2016-12-07T05:01:37Z

    Port ParDoTest from OldDoFn to new DoFn

commit ae52ec1bc3f3120e9f8e150e50c18564055a467c
Author: Kenneth Knowles <>
Date:   2016-12-07T17:00:18Z

    This closes #1529

commit 55d333bff68809ff1a9154491ace02d2d16e3b85
Author: Thomas Groh <>
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

commit 5b31a369962907e257de8019fbf6cde4c615b1c0
Author: Thomas Groh <>
Date:   2016-12-07T17:14:38Z

    This closes #1511

commit 43fef2775145f67def3ab8a246ecca192a7d650b
Author: Dan Halperin <>
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 <>
Date:   2016-12-07T22:55:03Z

    Closes #1533

commit 6439f701d1008d6a0432828e11e0fcc8a4fe6ecc
Author: Dan Halperin <>
Date:   2016-12-07T23:40:58Z

    [BEAM-1108] DataflowRunner: remove deprecated TEARDOWN_POLICY control

commit 3b2e0290ddbedd199926a70f36c02ea4515841cb
Author: Dan Halperin <>
Date:   2016-12-08T01:18:11Z

    Closes #1546

commit 1b1252074dd6b57f4fb88ceb82c704d3d3d8147f
Author: Alexey Diomin <>
Date:   2016-12-07T05:39:27Z

    [BEAM-1095] Add support set config for reuse-object on flink

commit c53e0b1623e3ee3c08c329e2716440f031681591
Author: Aljoscha Krettek <>
Date:   2016-12-08T01:44:07Z

    This closes #1518

commit f1a5704a505b01d7d4649b61d1f6697859367964
Author: Alexey Diomin <>
Date:   2016-12-07T05:48:35Z

    [BEAM-1096] Flink streaming side output optimization using SplitStream

commit 6807480a97f2315b3f48ad8dd5accb4e30475fa4
Author: Aljoscha Krettek <>
Date:   2016-12-08T01:55:32Z

    This closes #1520

commit 3f8c80769a3bb38da64c6628fd8c4669fcac794b
Author: Kenneth Knowles <>
Date:   2016-12-07T04:10:06Z

    Add DoFn.OnTimerContext

commit 2883062eebe8dba849ab89627f6aeb53266ac1a8
Author: Kenneth Knowles <>
Date:   2016-12-07T04:10:21Z

    Access to OnTimerContext via DoFnInvokers.ArgumentProvider

commit 42b506f06dbd73e03a2cfad4e7677e9698b3c020
Author: Kenneth Knowles <>
Date:   2016-12-07T04:18:18Z

    Add OnTimerContext parameter support to DoFnSignature


> Gearpump runner
> ---------------
>                 Key: BEAM-79
>                 URL:
>             Project: Beam
>          Issue Type: New Feature
>          Components: runner-gearpump
>            Reporter: Tyler Akidau
>            Assignee: Manu Zhang
> Intel is submitting Gearpump ( to ASF (
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

View raw message