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

Posted to commits@beam.apache.org by bo...@apache.org on 2019/12/27 20:14:25 UTC

[beam] branch master updated (4c34799 -> 614ca4e)

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

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


    from 4c34799  Merge pull request #10454 Set TMPDIR for tox environments
     add aeae2f4  Revert "[BEAM-8932]  Modify PubsubClient to use the proto message throughout."
     add 614ca4e  Merge pull request #10470 from apache/revert-10331-master

No new revisions were added by this update.

Summary of changes:
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   6 +-
 .../beam/sdk/io/gcp/pubsub/PubsubClient.java       | 139 ++++++++++++++++-----
 .../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java   |  29 +++--
 .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java    |   9 +-
 .../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java   |  28 ++---
 .../beam/sdk/io/gcp/pubsub/PubsubTestClient.java   |  11 +-
 .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java     |  23 ++--
 .../sdk/io/gcp/pubsub/PubsubUnboundedSource.java   |  33 +++--
 .../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java  |  20 +--
 .../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java   |   6 +-
 .../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java  |   1 -
 .../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java    |  19 ++-
 .../beam/sdk/io/gcp/pubsub/PubsubIOTest.java       |   8 +-
 .../sdk/io/gcp/pubsub/PubsubJsonClientTest.java    |  46 ++-----
 .../sdk/io/gcp/pubsub/PubsubTestClientTest.java    |  31 ++---
 .../sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java |  39 ++----
 .../io/gcp/pubsub/PubsubUnboundedSourceTest.java   |  28 ++---
 17 files changed, 226 insertions(+), 250 deletions(-)