From commits-return-114330-archive-asf-public=cust-asf.ponee.io@beam.apache.org Fri Jul 2 03:21:31 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 8BB3618064A for ; Fri, 2 Jul 2021 05:21:31 +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 B9EE141CB3 for ; Fri, 2 Jul 2021 03:21:30 +0000 (UTC) Received: (qmail 97506 invoked by uid 500); 2 Jul 2021 03:21:30 -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 97490 invoked by uid 99); 2 Jul 2021 03:21:30 -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, 02 Jul 2021 03:21:30 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 201718DC92; Fri, 2 Jul 2021 03:21:30 +0000 (UTC) Date: Fri, 02 Jul 2021 03:21:18 +0000 To: "commits@beam.apache.org" Subject: [beam] tag nightly-master updated (7b30339 -> 37fd13e) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162519607365.19693.10474716052215685425@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: 7b30339a64949bcb7c1bc11305b8c9ab49e12942 X-Git-Newrev: 37fd13e738185822af132fe2e457b618e766802f 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 7b30339 (commit) to 37fd13e (commit) from 7b30339 [BEAM-12548] Add EqualsList functionality to PAssert (#15110) add 7cfd330 [BEAM-11994] Update ShortIdMap's maps to only use valid keyable fields in the MonitoringInfo (urn and labels). add e4d27c1 Merge pull request #14804 from ajamato/bq_metrics_process_wide_short_ids add 22ec4e6 Add MatchContinuously PTransform to Python SDK (#15106) add f077ba5 [BEAM-10955] Fix Flink Java Runner test flake: Could not find Flink job (#15107) add ee236d6 Add support for BigQuery data types aliases to BigQueryAvroUtils add 1837ea5 Merge pull request #15060 from [BEAM-10176] Support STRUCT, FLOAT64, INT64 BigQuery types add 0715b66 [BEAM-12548] Add examples of Equals and EqualsList to equals_test.go (#15112) add d6088d3 [BEAM-12076] Adds a Kafka external read transform for reading with metadata (#15028) add fe8d522 Update _index.md add 360a1e5 Merge pull request #15047 from YuqiHuai/patch-1 add 999a77e [BEAM-12422] Remove all optional logging libraries as Netty attempts to detect a compatible logger internally add 37fd13e [BEAM-12422] Drop other optional logger libraries since Netty can detect which logger is available automatically No new revisions were added by this update. Summary of changes: .../apache/beam/gradle/GrpcVendoring_1_36_0.groovy | 5 - .../beam/runners/core/metrics/ShortIdMap.java | 3 + .../beam/runners/core/metrics/ShortIdMapTest.java | 133 ++++++++++++ .../beam/runners/flink/FlinkSavepointTest.java | 4 +- sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go | 2 +- sdks/go/pkg/beam/testing/passert/equals_test.go | 67 ++++++ .../sdk/expansion/ExternalTransformRegistrar.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 7 + .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 227 ++++++++++++++++++--- .../beam/sdk/io/kafka/KafkaIOExternalTest.java | 149 ++++++++++++-- .../apache_beam/examples/kafkataxi/kafka_taxi.py | 36 +++- sdks/python/apache_beam/io/fileio.py | 74 +++++++ sdks/python/apache_beam/io/fileio_test.py | 66 ++++++ sdks/python/apache_beam/io/kafka.py | 12 +- website/www/site/content/en/contribute/_index.md | 2 +- 15 files changed, 729 insertions(+), 60 deletions(-) create mode 100644 runners/core-java/src/test/java/org/apache/beam/runners/core/metrics/ShortIdMapTest.java