beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (7b30339 -> 37fd13e)
Date Fri, 02 Jul 2021 03:21:18 GMT
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

Mime
View raw message