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 <[email protected]> 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(-)
