GitHub user manuzhang opened a pull request: https://github.com/apache/beam/pull/3479
[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: - [ ] Make sure the PR title is formatted like: `[BEAM-<Jira issue #>] Description of pull request` - [ ] Make sure tests pass via `mvn clean verify`. - [ ] Replace `<Jira issue #>` in the title with the actual Jira issue number, if there is one. - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf). --- You can merge this pull request into a Git repository by running: $ git pull https://github.com/manuzhang/beam sync-master Alternatively you can review and apply these changes as the patch at: https://github.com/apache/beam/pull/3479.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 #3479 ---- commit cab4d8969e7f95b0ece59838ad2d578e75d38823 Author: Kenneth Knowles <k...@google.com> Date: 2017-06-22T03:25:31Z DataflowRunner: Reject merging windowing for stateful ParDo commit 5f8cfa7412e8f4ce97d6df4413fecbea22b4b5e1 Author: Kenneth Knowles <k...@google.com> Date: 2017-06-23T03:05:28Z This closes #3419: DataflowRunner: Reject merging windowing for stateful ParDo commit 649994b353afe28c917969609c7a1a47a4f39aaf Author: Rune Fevang <fev...@exabel.com> Date: 2017-06-15T11:51:12Z Allow output from FinishBundle in DoFnTester commit b3c36256e32f4a4a616d0e152686d29f1174c5cd Author: Kenneth Knowles <k...@google.com> Date: 2017-06-23T03:07:48Z This closes #3367: Allow output from FinishBundle in DoFnTester commit 8dcda6e40355af13f4d92fcd44aae4539a225a4a Author: Sourabh Bajaj <sourabhba...@google.com> Date: 2017-06-23T00:08:20Z [BEAM-2497] Fix the reading of concat gzip files commit 336b7f1cffc8709cd480a243a16de95bce39b53e Author: Chamikara Jayalath <chamik...@google.com> Date: 2017-06-23T05:13:05Z This closes #3428 commit f291713b28e3ba0246a8c0a710c71506cd0a0f91 Author: Etienne Chauchot <echauc...@gmail.com> Date: 2017-06-21T08:39:39Z [BEAM-2489] Use dynamic ES port in HIFIOWithElasticTest commit 6cef5c7b625c6b5c2078084ba611b1c2adccc998 Author: Jean-Baptiste Onofré <jbono...@apache.org> Date: 2017-06-23T13:01:42Z [BEAM-2489] This closes #3411 commit fd8f15f1ac761425dc791a455b042a8846081f48 Author: Mark Liu <mark...@google.com> Date: 2017-06-22T21:04:00Z [BEAM-2745] Add Jenkins Suite for Python Performance Test commit af69e979ab3037274bdd78904bdeb5016563bcad Author: Ahmet Altay <al...@google.com> Date: 2017-06-23T21:03:17Z This closes #3426 commit 32095487e56b63b5c1aa690bb6e098375cb108d5 Author: Vikas Kedigehalli <vika...@google.com> Date: 2017-06-23T18:50:12Z Fix python fn API data plane remote grpc port access commit 9acce7150ee8fa6c9e50049155ad7b85b646f98e Author: Ahmet Altay <al...@google.com> Date: 2017-06-23T22:13:30Z This closes #3431 commit 903da41ac5395e76c44ef8ae1c8a695569e23abb Author: Robert Bradshaw <rober...@gmail.com> Date: 2017-06-23T22:01:42Z Avoid pickling the entire pipeline per-transform. commit a90e40ae9f748c1c8392c1198469f3229a06ed70 Author: Robert Bradshaw <rober...@gmail.com> Date: 2017-06-23T23:39:52Z Closes #3433 commit e45f522d6e945899c20259ebf8faca105c2e552e Author: Valentyn Tymofieiev <valen...@google.com> Date: 2017-06-23T23:44:49Z Fix a typo in function args commit 16f87f49f20796e29d01ed363a9097ea5420583c Author: Ahmet Altay <al...@google.com> Date: 2017-06-24T00:34:21Z This closes #3435 commit 926f949580c3a21df72a8836feda1f6b947850ec Author: Charles Chen <c...@google.com> Date: 2017-06-26T20:00:14Z Remove old deprecated PubSub code commit 1ea1de4aa9d32e3c5a596ccd7d84aff1cc2a7428 Author: Ahmet Altay <al...@google.com> Date: 2017-06-26T21:23:08Z This closes #3440 commit bec32fe93c6b5c16563d7ea4b877a2dee3352fee Author: Eugene Kirpichov <kirpic...@google.com> Date: 2017-06-16T21:56:07Z Reintroduces DoFn.ProcessContinuation (Dataflow worker compatibility part) commit 2052cc7689b4ed53f817f56dd71a32235fb083ca Author: Eugene Kirpichov <kirpic...@google.com> Date: 2017-06-23T17:16:30Z Bump Dataflow worker to 0623 commit 95e6bbe5065a983f9c71b79b20df1fda83c9fd1b Author: Eugene Kirpichov <kirpic...@google.com> Date: 2017-06-27T00:25:14Z This closes #3383: [BEAM-2447] Reintroduces DoFn.ProcessContinuation (Dataflow worker compatibility part) commit eb379e76adaa9c4b4e24a4b3c5757be8523d95c4 Author: Charles Chen <c...@google.com> Date: 2017-06-26T23:54:00Z Implement streaming GroupByKey in Python DirectRunner commit 8036001da6f90eac20d787a05d35a51e30146278 Author: Ahmet Altay <al...@google.com> Date: 2017-06-27T05:49:19Z This closes #3444 commit cbfcad823972270171552e556b7fa8d8d4882f14 Author: Jean-Baptiste Onofré <jbono...@apache.org> Date: 2016-12-28T14:06:09Z [BEAM-1237] Create AmqpIO commit 9df865add9bdd83d265d0f8442e6b07467bcf17d Author: Jean-Baptiste Onofré <jbono...@apache.org> Date: 2017-06-27T13:33:51Z [BEAM-1237] This closes #1725 commit 01b3febc62debf8b4fd1582225d59768d231601a Author: manuzhang <owenzhang1...@gmail.com> Date: 2017-06-26T12:55:13Z [BEAM-2514] Improve error message on missing required value commit 99ef92bc97692bdba3ea8e10cc09d81f3d64b69b Author: Luke Cwik <lc...@google.com> Date: 2017-06-27T16:23:03Z [BEAM-2514] Improve error message on missing required value This closes #3438 commit d33d64644c8ddc74a3dc07bf0c642a9ed818a624 Author: Nigel Kilmer <nkil...@google.com> Date: 2017-06-21T18:26:10Z Removed uses of proto builder clone method commit e93c06485508ae3a7a8304be3d6127d604d9356e Author: Luke Cwik <lc...@google.com> Date: 2017-06-27T16:40:53Z [BEAM-2392] Remove uses of proto builder clone This closes #3415 commit 8dd0077d2a58e278b11c7e7eb4b5f182e1400992 Author: Vikas Kedigehalli <vika...@google.com> Date: 2017-06-27T01:47:39Z Enable grpc controller in fn_api_runner ---- --- 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---