You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/11/13 04:40:35 UTC

[beam] branch nightly-refs/heads/master updated (4b96193250a -> aa0a35dabf9)

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 4b96193250a Remove TheNeuralBit from the pool of Python reviewers (#24108)
     add b2d28a64bb0 Add TFX support in pydoc (#23960)
     add 027fb142038 Bump cloud.google.com/go/bigtable from 1.17.0 to 1.18.0 in /sdks (#24113)
     add 3a6fcc1ca4d disable (#24121)
     add 9fcd20c3712 Implement PubsubRowToMessage transform (#23897)
     add 836766ddb83 upgrade testcontainer dependency (#24123)
     add 96f9da1ab65 More cleanup containers (#24105)
     add 6557c91c794 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#24112)
     add c2021bee1eb Bump google.golang.org/api from 0.102.0 to 0.103.0 in /sdks (#24049)
     add 5d2dbf957e4 Update staging of Python wheels (#24114)
     add 369e2ba8622 Add a ValidatesContainer integration test for use_sibling_sdk_workers (#24099)
     add aa0a35dabf9 Fix checkArgument format string in TestStream (#24134)

No new revisions were added by this update.

Summary of changes:
 .github/workflows/playground_examples_ci.yml       |   10 +-
 .../jenkins/job_CleanUpPrebuiltSDKImages.groovy    |    2 +-
 .../tools/stale_dataflow_prebuilt_image_cleaner.sh |   68 +-
 sdks/go.mod                                        |   24 +-
 sdks/go.sum                                        |   54 +-
 .../go/test/integration/io/xlang/jdbc/jdbc_test.go |    5 +-
 .../org/apache/beam/sdk/testing/TestStream.java    |    2 +-
 .../beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java |  577 +++++++++++
 .../sdk/io/gcp/pubsub/PubsubRowToMessageTest.java  | 1085 ++++++++++++++++++++
 .../apache_beam/examples/wordcount_it_test.py      |    4 +
 sdks/python/apache_beam/ml/inference/__init__.py   |    5 +
 .../apache_beam/runners/portability/stager.py      |   20 +-
 .../apache_beam/runners/portability/stager_test.py |    2 +
 sdks/python/container/boot.go                      |    6 +-
 sdks/python/setup.py                               |    2 +-
 15 files changed, 1786 insertions(+), 80 deletions(-)
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubRowToMessageTest.java