From commits-return-114479-archive-asf-public=cust-asf.ponee.io@beam.apache.org Fri Jul 23 03:23:19 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 22834180626 for ; Fri, 23 Jul 2021 05:23:19 +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 5BF0E4552A for ; Fri, 23 Jul 2021 03:23:18 +0000 (UTC) Received: (qmail 9401 invoked by uid 500); 23 Jul 2021 03:23:16 -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 9392 invoked by uid 99); 23 Jul 2021 03:23:16 -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; Fri, 23 Jul 2021 03:23:16 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 03FED81F23; Fri, 23 Jul 2021 03:23:15 +0000 (UTC) Date: Fri, 23 Jul 2021 03:23:04 +0000 To: "commits@beam.apache.org" Subject: [beam] tag nightly-master updated (61a884e -> b8e390a) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162701057995.4874.12048338837718550546@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: 61a884eafd66edae7df461226d3110235f88affd X-Git-Newrev: b8e390aeb83a6bb05a54bbb16bfb239d0fbd9e10 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 61a884e (commit) to b8e390a (commit) from 61a884e Merge pull request #15182 from pcoet/website-docs add 09d4fab Default to Runner v2 for Python Streaming jobs. (#15140) add 31c2b76 Moving to 2.33.0-SNAPSHOT on master branch. add e8f9ad9 [BEAM-12548] Fix malformed comment for EqualsFloat (#15200) add bbe7b64 [BEAM-4152] Implement session window merging in the Go direct runner (#15196) add f88ed4e [BEAM-12643] Resolved the concurrent writes issue for parallel tests (#15199) add 63257ed [BEAM-10212] Add caching state client wrapper (#15170) add 2d7c4a8 [BEAM-12625] Annotate testTwoTimersSettingEachOtherWithCreateAsInputUnbounded. add b8e390a Merge pull request #15205 from ibzib/BEAM-12625 No new revisions were added by this update. Summary of changes: .../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +- gradle.properties | 4 +- sdks/go/pkg/beam/core/core.go | 2 +- sdks/go/pkg/beam/core/util/hooks/hooks.go | 124 ++++++-- sdks/go/pkg/beam/core/util/hooks/hooks_test.go | 60 +++- sdks/go/pkg/beam/runners/direct/gbk.go | 109 ++++++- sdks/go/pkg/beam/runners/direct/gbk_test.go | 88 ++++++ sdks/go/pkg/beam/testing/passert/floats.go | 2 +- sdks/go/test/integration/integration.go | 2 - .../org/apache/beam/sdk/transforms/ParDoTest.java | 7 +- .../fn/harness/state/CachingBeamFnStateClient.java | 178 +++++++++++ .../state/CachingBeamFnStateClientTest.java | 335 +++++++++++++++++++++ .../fn/harness/state/FakeBeamFnStateClient.java | 4 + .../runners/dataflow/dataflow_runner.py | 8 +- .../runners/dataflow/dataflow_runner_test.py | 11 +- sdks/python/apache_beam/version.py | 2 +- 16 files changed, 872 insertions(+), 66 deletions(-) create mode 100644 sdks/go/pkg/beam/runners/direct/gbk_test.go create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClient.java create mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClientTest.java