From commits-return-114570-archive-asf-public=cust-asf.ponee.io@beam.apache.org Wed Aug 11 03:09:56 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id 99C8E180634 for ; Wed, 11 Aug 2021 05:09:56 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id C77A53F6E3 for ; Wed, 11 Aug 2021 03:09:55 +0000 (UTC) Received: (qmail 14580 invoked by uid 500); 11 Aug 2021 03:09:54 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 14571 invoked by uid 99); 11 Aug 2021 03:09:53 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 11 Aug 2021 03:09:53 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 3F0E781F26; Wed, 11 Aug 2021 03:09:53 +0000 (UTC) Date: Wed, 11 Aug 2021 03:09:42 +0000 To: "commits@beam.apache.org" Subject: [beam] tag nightly-master updated (2fd9875 -> b9b4c6e) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162865137760.13686.3827505594732960679@gitbox.apache.org> From: github-bot@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: beam X-Git-Refname: refs/tags/nightly-master X-Git-Reftype: tag X-Git-Oldrev: 2fd98755f21befaade118de9b7bd632737094f28 X-Git-Newrev: b9b4c6e1f142d3fcb93f6a4458e2a06282ab9ee8 X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to tag nightly-master in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag nightly-master was modified! *** from 2fd9875 (commit) to b9b4c6e (commit) from 2fd9875 Merge pull request #15269 from ihji/BEAM-12716 add d980232 Fix typo add 09548a9 Merge pull request #15302 from chamikaramj/fix_doc_typo add b5820a2 [BEAM-12403][BEAM-12348] Add User State Support for Portable SamzaRunner (#15280) add e6f80a1 Update beam dataflow python container versions. add ce406c6 Merge pull request #15305 from y1chi/update_py_container add f4f5489 Update Google Cloud Healthcare API version from v1beta1 to GA (v1-rev20210603) add 927aae5 Merge pull request #15268 from Update Google Cloud Healthcare API version from v1beta1 to GA add 9e8fae7 Add support for python sdk container to turn on google cloud profiler via dataflow service options add 3d5b221 format file add b9b4c6e Merge pull request #15296 from andyxiexu/python-sdk No new revisions were added by this update. Summary of changes: CHANGES.md | 1 + .../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +- runners/samza/job-server/build.gradle | 2 - .../apache/beam/runners/samza/runtime/DoFnOp.java | 41 +++--- .../beam/runners/samza/runtime/GroupByKeyOp.java | 4 +- .../runners/samza/runtime/SamzaDoFnRunners.java | 44 ++++++- .../samza/runtime/SamzaStateRequestHandlers.java | 146 ++++++++++++++++++--- .../samza/runtime/SamzaStoreStateInternals.java | 58 ++++++-- .../SplittableParDoProcessKeyedElementsOp.java | 4 +- .../translation/ParDoBoundMultiTranslator.java | 50 ++++++- .../beam/runners/samza/util/StateUtils.java} | 27 ++-- .../runtime/SamzaTimerInternalsFactoryTest.java | 6 +- .../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 24 ++-- .../apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java | 27 ++-- .../beam/sdk/io/gcp/healthcare/HL7v2Message.java | 4 +- .../sdk/io/gcp/healthcare/HL7v2MessageCoder.java | 2 +- .../sdk/io/gcp/healthcare/HealthcareApiClient.java | 20 +-- .../io/gcp/healthcare/HttpHealthcareApiClient.java | 61 +++++---- .../beam/sdk/io/gcp/healthcare/FhirIOLROIT.java | 2 +- .../io/gcp/healthcare/HL7V2MessagePagesTest.java | 4 +- .../beam/sdk/io/gcp/healthcare/HL7v2IOTest.java | 2 +- .../sdk/io/gcp/healthcare/HL7v2IOTestUtil.java | 2 +- .../beam/sdk/io/gcp/healthcare/HL7v2IOWriteIT.java | 2 +- .../apache_beam/runners/dataflow/internal/names.py | 4 +- .../runners/portability/samza_runner_test.py | 20 +-- .../apache_beam/runners/worker/sdk_worker_main.py | 9 +- .../www/site/content/en/documentation/glossary.md | 4 +- .../content/en/documentation/programming-guide.md | 2 +- 28 files changed, 388 insertions(+), 186 deletions(-) copy runners/{java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ExecutableStageContext.java => samza/src/main/java/org/apache/beam/runners/samza/util/StateUtils.java} (55%)