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/09/09 03:06:14 UTC
[beam] tag nightly-master updated (ba89e76 -> 2bb60c3)
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 ba89e76 (commit)
to 2bb60c3 (commit)
from ba89e76 Merge pull request #12778 from SergiyKolesnikov/BEAM-10661
add 2579d48 [BEAM-10672] Move StatefulLoadGenerator from pardo_test.py
add 27df907 [BEAM-10672] Several fixes to init actions for Dataproc cluster
add 66458f2 [BEAM-10672] Add Python Combine Load Tests for streaming on Flink
add b59e8af [BEAM-10672] Use customized image tags
add 051fbc8 [BEAM-10672] Update Load tests jobs README
add 9f3a894 fix: separate job for building Docker images
add d4e3729 Merge pull request #12698: [BEAM-10672] Add Python Combine Load Tests for streaming on Flink
add 26b087b [BEAM-10760] Generalize state cleanup optimization for global window
add 5fd0010 Merge pull request #12759: [BEAM-10760] Generalize state cleanup optimization for global window
add 4d43767 [BEAM-3612] Augment supported container types. (#12785)
add efc2080 Update codecov.yml
add d2fc192 Merge pull request #12739 [BEAM-10840] Don't run code coverage on microbenchmarks
add 71d5395 Merge pull request #12703 from [BEAM-10603] Add describe and cancel to RecordingManager
add 641683d Add support for multiple inputs
add 916d4e8 Add tests for multiple inputs in PTransformOverride
add f923da1 Lint
add 900ab9a Merge pull request #12655: [BEAM-10779] Support multiple main inputs and side inputs for PTransformOverride
add 2a20847 Support updating from a job in DRAINING state
add 2bb60c3 Merge pull request #12789 from edre/patch-1
No new revisions were added by this update.
Summary of changes:
.github/codecov.yml | 1 +
.test-infra/dataproc/init-actions/docker.sh | 4 +-
.test-infra/dataproc/init-actions/flink.sh | 6 +-
.test-infra/jenkins/Docker.groovy | 75 --------
.test-infra/jenkins/README.md | 26 +--
.../job_LoadTests_Combine_Flink_Python.groovy | 117 ++++++++-----
.../jenkins/job_LoadTests_Combine_Python.groovy | 4 +-
.../jenkins/job_LoadTests_GBK_Flink_Python.groovy | 30 ++--
.../job_LoadTests_ParDo_Flink_Python.groovy | 59 +++----
.../jenkins/job_LoadTests_ParDo_Python.groovy | 2 +-
.../job_LoadTests_coGBK_Flink_Python.groovy | 19 ++-
...Commit_Python_Chicago_Taxi_Example_Flink.groovy | 16 +-
....groovy => job_Publish_Docker_Snapshots.groovy} | 23 ++-
.../wrappers/streaming/DoFnOperator.java | 24 ++-
.../streaming/ExecutableStageDoFnOperator.java | 32 +---
.../streaming/state/FlinkStateInternals.java | 96 ++++++++---
.../wrappers/streaming/DoFnOperatorTest.java | 190 ++++++++++++++-------
.../streaming/ExecutableStageDoFnOperatorTest.java | 39 +----
sdks/go/pkg/beam/util/starcgenx/starcgenx.go | 35 +++-
sdks/go/pkg/beam/util/starcgenx/starcgenx_test.go | 18 ++
sdks/python/apache_beam/pipeline.py | 34 ++--
sdks/python/apache_beam/pipeline_test.py | 94 ++++++++++
.../runners/dataflow/internal/apiclient.py | 5 +-
.../interactive/options/capture_limiters.py | 2 +-
.../interactive/options/capture_limiters_test.py | 2 +-
.../runners/interactive/pipeline_instrument.py | 7 +
.../runners/interactive/recording_manager.py | 85 +++++++--
.../runners/interactive/recording_manager_test.py | 179 ++++++++++++++++++-
.../apache_beam/testing/load_tests/combine_test.py | 24 ++-
.../apache_beam/testing/load_tests/pardo_test.py | 69 +-------
.../apache_beam/testing/synthetic_pipeline.py | 69 ++++++++
31 files changed, 910 insertions(+), 476 deletions(-)
delete mode 100644 .test-infra/jenkins/Docker.groovy
copy .test-infra/jenkins/{job_CancelStaleDataflowJobs.groovy => job_Publish_Docker_Snapshots.groovy} (67%)