You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by bh...@apache.org on 2020/08/11 22:09:02 UTC

[beam] branch master updated (abbd849 -> ef533ee)

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

bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from abbd849  Merge pull request #12515 from robinyqiu/update
     add ef533ee  [BEAM-10571] Use schemas in ExternalConfigurationPayload (#12481)

No new revisions were added by this update.

Summary of changes:
 .../src/main/proto/external_transforms.proto       |  16 +-
 .../core/construction/ValidateRunnerXlangTest.java |  25 +-
 sdks/java/expansion-service/build.gradle           |   4 +
 .../sdk/expansion/service/ExpansionService.java    | 223 +++++++++------
 .../expansion/service/ExpansionServiceTest.java    | 310 ++++++++++++++-------
 .../sdk/io/gcp/pubsub/PubsubIOExternalTest.java    |  72 ++---
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |  24 +-
 .../beam/sdk/io/kafka/KafkaIOExternalTest.java     | 117 ++++----
 sdks/python/apache_beam/io/kafka.py                |   8 +-
 .../runners/portability/expansion_service_test.py  |  10 +-
 sdks/python/apache_beam/transforms/external.py     | 135 +++++----
 .../python/apache_beam/transforms/external_test.py | 126 +++------
 .../apache_beam/transforms/external_test_py3.py    |   8 +-
 .../apache_beam/transforms/external_test_py37.py   |   4 +-
 14 files changed, 591 insertions(+), 491 deletions(-)