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

Posted to commits@beam.apache.org by ch...@apache.org on 2021/01/30 01:50:09 UTC

[beam] 01/01: Merge pull request #13826: Cherrypick Merge pull request #13797 from [BEAM-11679] Override PubsubUnboundedS…

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

chamikara pushed a commit to branch release-2.28.0
in repository https://gitbox.apache.org/repos/asf/beam.git

commit d9d4c99871b4882a3d8995e8beb7dcea8f727a99
Merge: d856479 3bd01f8
Author: Chamikara Jayalath <ch...@apache.org>
AuthorDate: Fri Jan 29 17:49:30 2021 -0800

    Merge pull request #13826: Cherrypick Merge pull request #13797 from [BEAM-11679] Override PubsubUnboundedS…

 build.gradle                                       |   1 +
 runners/google-cloud-dataflow-java/build.gradle    |  13 +-
 .../beam/runners/dataflow/DataflowRunner.java      | 207 ++++++++++++++++-----
 .../beam/runners/dataflow/TestDataflowRunner.java  |   6 +-
 .../beam/sdk/testing/TestPipelineOptions.java      |  10 +
 .../beam/sdk/io/gcp/pubsub/PubsubMessages.java     |   7 +-
 .../beam/sdk/io/gcp/pubsub/PubsubReadIT.java       |   6 +-
 7 files changed, 185 insertions(+), 65 deletions(-)