Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 94A46200BE7 for ; Tue, 20 Dec 2016 15:42:54 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 93302160B29; Tue, 20 Dec 2016 14:42:54 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B30E8160B1B for ; Tue, 20 Dec 2016 15:42:53 +0100 (CET) Received: (qmail 57840 invoked by uid 500); 20 Dec 2016 14:42:52 -0000 Mailing-List: contact commits-help@beam.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.incubator.apache.org Delivered-To: mailing list commits@beam.incubator.apache.org Received: (qmail 57831 invoked by uid 99); 20 Dec 2016 14:42:52 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Dec 2016 14:42:52 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 578D21A9B74 for ; Tue, 20 Dec 2016 14:42:52 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.768 X-Spam-Level: X-Spam-Status: No, score=-6.768 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, KAM_LOTSOFHASH=0.25, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id G-7inopM4qnY for ; Tue, 20 Dec 2016 14:42:50 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id A80455FDB7 for ; Tue, 20 Dec 2016 14:42:44 +0000 (UTC) Received: (qmail 57777 invoked by uid 99); 20 Dec 2016 14:42:43 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Dec 2016 14:42:43 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id B3208DFB85; Tue, 20 Dec 2016 14:42:43 +0000 (UTC) From: manuzhang To: commits@beam.incubator.apache.org Reply-To: commits@beam.incubator.apache.org Message-ID: Subject: [GitHub] incubator-beam pull request #1663: [BEAM-79] merge master into gearpump-runn... Content-Type: text/plain Date: Tue, 20 Dec 2016 14:42:43 +0000 (UTC) archived-at: Tue, 20 Dec 2016 14:42:54 -0000 GitHub user manuzhang opened 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: - [ ] Make sure the PR title is formatted like: `[BEAM-] 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). - [ ] Replace `` 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.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 0af145bba721f7cdf3fbcd15330df433d5a8431d Author: Davor Bonaci Date: 2016-12-07T01:00:31Z This closes #1504 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 graph. 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 ---- --- 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 infrastructure@apache.org or file a JIRA ticket with INFRA. ---