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 2020/11/26 02:45:08 UTC

[beam] tag nightly-master updated (b21b573 -> 8cdb807)

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

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


*** WARNING: tag nightly-master was modified! ***

    from b21b573  (commit)
      to 8cdb807  (commit)
    from b21b573  Merge pull request #13422 from apache/aaltay-patch-1
     add 331924f  [BEAM-9980] do not use hardcoded python versions in validate container dataflow jobs (#13382)
     add 0db6f9a  [BEAM-9980] do not use hardcoded python versions in chicago taxi example flink job (#13412)
     add e58246d  Go SDK Combine load tests (#13389)
     add ad0c7f6  Go SDK Group by key load tests (#13388)
     add f8e8daf  [BEAM-10278] Move pipeline jar tests from job server projects to python/test-suites/portable.
     add b002530  Merge pull request #13417 from ibzib/BEAM-10278
     add 72b8894  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add 50aaf77  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add 296f3a4  Merge branch 'master' into multi-pubsub-reader
     add d0263c7  Merge remote-tracking branch 'origin/multi-pubsub-reader' into multi-pubsub-reader
     add 34b92bf  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add e046a63  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add 660cdf5  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add dfc57ee  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add 0a0dc6b  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add c33e97f  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add 2508a4f  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add 2e7bc4a  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add a279c7d  [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add 17af76c  Merge branch 'master' into multi-pubsub-reader
     add 682f2ea  Merge pull request #12930 from [BEAM-10962] Add Multiple PubSub reader to Python SDK
     add d29095d  Advance the chromedriver-binary version with new screenshots.
     add 545db73  Merge pull request #13423 from KevinGG/BEAM-11045
     add e24eb88  [BEAM-11342] fix google3 import error
     add fb02df3  add logging
     add 8cdb807  Merge pull request #13425 from ihji/BEAM-11342

No new revisions were added by this update.

Summary of changes:
 .test-infra/jenkins/PythonTestProperties.groovy    |  13 +-
 ...roovy => job_LoadTests_Combine_Flink_Go.groovy} | 104 +++++-----
 .../jenkins/job_LoadTests_GBK_Flink_Go.groovy      | 220 +++++++++++++++++++++
 .../job_PostCommit_PortableJar_Flink.groovy        |   3 +-
 .../job_PostCommit_PortableJar_Spark.groovy        |   2 +-
 ...Commit_Python_Chicago_Taxi_Example_Flink.groovy |   8 +-
 ...ommit_Python_ValidatesContainer_Dataflow.groovy |   9 +-
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   5 +
 runners/flink/job-server/flink_job_server.gradle   |  66 -------
 .../test_flink_uber_jar.sh                         |   0
 runners/portability/test_pipeline_jar.sh           |   3 +-
 runners/spark/job-server/build.gradle              |  32 ---
 sdks/go/test/load/build.gradle                     |   2 +
 .../load/{pardo/pardo.go => combine/combine.go}    |  71 +++----
 .../pardo.go => group_by_key/group_by_key.go}      |  69 +++----
 sdks/python/apache_beam/io/gcp/pubsub.py           | 114 +++++++++++
 sdks/python/apache_beam/io/gcp/pubsub_test.py      | 123 ++++++++++++
 .../Linux/7a35f487b2a5f3a9b9852a8659eeb4bd.png     | Bin 700548 -> 703677 bytes
 sdks/python/setup.py                               |   2 +-
 sdks/python/test-suites/portable/common.gradle     |  69 ++++++-
 20 files changed, 651 insertions(+), 264 deletions(-)
 copy .test-infra/jenkins/{job_LoadTests_ParDo_Flink_Go.groovy => job_LoadTests_Combine_Flink_Go.groovy} (55%)
 create mode 100644 .test-infra/jenkins/job_LoadTests_GBK_Flink_Go.groovy
 rename runners/{flink/job-server => portability}/test_flink_uber_jar.sh (100%)
 copy sdks/go/test/load/{pardo/pardo.go => combine/combine.go} (58%)
 copy sdks/go/test/load/{pardo/pardo.go => group_by_key/group_by_key.go} (59%)