From commits-return-114541-archive-asf-public=cust-asf.ponee.io@beam.apache.org Thu Aug 5 03:43:15 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 F1368180660 for ; Thu, 5 Aug 2021 05:43:14 +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 38DA63F971 for ; Thu, 5 Aug 2021 03:43:14 +0000 (UTC) Received: (qmail 72203 invoked by uid 500); 5 Aug 2021 03:43:13 -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 72187 invoked by uid 99); 5 Aug 2021 03:43:12 -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; Thu, 05 Aug 2021 03:43:12 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 5A13181F23; Thu, 5 Aug 2021 03:43:12 +0000 (UTC) Date: Thu, 05 Aug 2021 03:43:00 +0000 To: "commits@beam.apache.org" Subject: [beam] tag nightly-master updated (92ea5f5 -> 39cf3fc) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162813497555.10122.528254992216957162@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: 92ea5f547e2ac3dfd46e20b7c965f8a4850f2238 X-Git-Newrev: 39cf3fccbb3950b9fd0c8938301d192c3ca85cce 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 92ea5f5 (commit) to 39cf3fc (commit) from 92ea5f5 [BEAM-11088] Add TestStream package to Go SDK testing capabilities (#15253) add 8b6f675 Merge pull request #15272:[BEAM-12712] Exclude runners that can't handle looping timers add 3a84a78 [BEAM-12703] Fix universal metrics. (#15260) add ec62170 [BEAM-12702] Pull step unique names from pipeline for metrics. (#15261) add e11fbba fix GroupIntoBatches add 03a1cca Merge pull request #15273: [BEAM-12720] fix GroupIntoBatches incorrectly clearing variables after outputting them add 74963dc [BEAM-12715] Use shard number specified by user in SnowflakeIO batch writeFiles add 3898642 Merge pull request #15255: [BEAM-12715] Snowflake IO use getShards in batch write mode add dbb44bf [BEAM-12678] Add dependency of java jars when running go VR on portable runners (#15276) add 64188aa [BEAM-12671] Mark known composite transforms native (#15236) add 2c7911b [BEAM-12670] Relocate bq client exception imports to try block and conditionally turn off tests if imports fail add 39cf3fc Merge pull request #15264 from [BEAM-12670] Relocate bq client exception imports to try block and conditionally turn off tests if imports fail No new revisions were added by this update. Summary of changes: CHANGES.md | 1 + runners/direct-java/build.gradle | 2 + runners/flink/flink_runner.gradle | 1 + .../runners/dataflow/GroupIntoBatchesOverride.java | 4 +- runners/samza/build.gradle | 1 + runners/samza/job-server/build.gradle | 5 +- .../beam/runners/samza/SamzaPipelineRunner.java | 17 ++- .../SamzaPortablePipelineTranslator.java | 27 +++- ....java => SamzaPortableTranslatorRegistrar.java} | 4 +- sdks/go/pkg/beam/core/metrics/metrics.go | 54 ++++++-- sdks/go/pkg/beam/core/metrics/metrics_test.go | 144 +++++++++++++++++++++ .../beam/runners/dataflow/dataflowlib/execute.go | 7 +- .../beam/runners/dataflow/dataflowlib/metrics.go | 22 ++-- .../runners/dataflow/dataflowlib/metrics_test.go | 34 ++--- sdks/go/test/build.gradle | 7 + .../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 3 +- sdks/python/apache_beam/io/gcp/bigquery_tools.py | 3 +- .../apache_beam/io/gcp/bigquery_tools_test.py | 11 +- .../runners/portability/samza_runner_test.py | 6 + 19 files changed, 293 insertions(+), 60 deletions(-) copy runners/samza/src/main/java/org/apache/beam/runners/samza/translation/{SamzaTranslatorRegistrar.java => SamzaPortableTranslatorRegistrar.java} (89%)