This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f91bb68b2e9 Add some simple annotations to Python transforms. (#28191)
add 29810a32164 added call to gcloud to setup the docker credential helper
(#28252)
add 9a06c9eca6d remove jenkins PostCommit BeamMetrics job (#28260)
add a43ee6fd983 remove sync stub list from GrpcWindmillServer (#28016)
add a65f55b4ec2 Add Java PVR Flink Batch action (#28221)
add 205083dd72f Keep track of metrics at the KeyedModelHandler level
(#28228)
add 262a2dac6c3 Upgrade pylint, re-enable bad-builtins check (#28239)
add c75975a569d Remove more legacy Runner v1 cruft.
add 0b11e2670f8 Make runner entrypoint more portable.
add 6ab14abc014 lint
add b776ce62a9c Lint, typing, test fix.
add 1cfc0fdc6ff Add an simple runner for pedagogical purposes.
add a13a584b986 Merge branch 'master' into trivial-runner
add 84922403b4f fix up some types
add a65779ca0fa rat
add d4c0dcd7172 cleanup
add b3cd8ecf45c import order
add 4fbc1c0a74f Add test clause.
add 4600517b4cd Merge pull request #27631 Add a simple runner for
pedagogical purposes.
add c1f3e129be6 Add Publish JUnit Test Results Action (#28075)
add 50392e97e8a Add Python PVR Flink action (#28222)
add 1294e730ef1 Python nightly snapshot release workflow (#28197)
add 913f00012c6 Generate separate tmp folder for TestSamzaRunner state
store (#28265)
add 31c6af443ca Implement initial version of the BufferedLogger (#28202)
add fd22129cee0 Fix java17 PostCommit ARM test config issue (#28234)
add 56d5341d201 Add guidance on container versioning (#28269)
add ddd74c68138 Use direct runner to avoid logging flake. (#28271)
add f32252832db Reference the memory leak in CHANGES.md (#28247)
add a472d1a004c Add support for limiting number of models in memory
(#28263)
add 3ff66d38c41 Add relative median threshold filtering to perf alert tool
(#28237)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 2 +
.../beam_PostCommit_BeamMetrics_Publish.yml | 21 +-
...yml => beam_PreCommit_Java_PVR_Flink_Batch.yml} | 48 +--
...hon.yml => beam_PreCommit_Python_PVR_Flink.yml} | 87 ++---
.github/workflows/beam_PreCommit_SQL_Java17.yml | 13 +-
...yml => beam_Release_Python_NightlySnapshot.yml} | 67 ++--
.pre-commit-config.yaml | 2 +-
.../job_PostCommit_BeamMetrics_Publish.groovy | 41 --
.../job_Release_Python_NightlySnapshot.groovy | 60 ---
CHANGES.md | 9 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 13 +-
.../apache/beam/examples/snippets/Snippets.java | 11 +-
.../grpcclient/GrpcDeadlineClientInterceptor.java | 58 +++
.../windmill/grpcclient/GrpcWindmillServer.java | 154 +++-----
.../grpcclient/GrpcWindmillServerTest.java | 71 ++++
.../apache/beam/runners/samza/TestSamzaRunner.java | 39 +-
sdks/go/container/tools/buffered_logging.go | 78 ++++
sdks/go/container/tools/buffered_logging_test.go | 169 +++++++++
sdks/go/pkg/beam/x/debug/head_test.go | 4 +-
sdks/python/.pylintrc | 23 +-
sdks/python/apache_beam/ml/inference/base.py | 161 ++++++--
sdks/python/apache_beam/ml/inference/base_test.py | 131 ++++++-
sdks/python/apache_beam/runners/common.py | 8 +
.../runners/portability/fn_api_runner/execution.py | 9 +-
.../portability/fn_api_runner/translations.py | 31 +-
.../runners/portability/portable_runner.py | 33 +-
sdks/python/apache_beam/runners/runner.py | 38 +-
sdks/python/apache_beam/runners/trivial_runner.py | 416 +++++++++++++++++++++
.../apache_beam/runners/trivial_runner_test.py | 74 ++++
.../testing/analyzers/perf_analysis_test.py | 21 +-
.../testing/analyzers/perf_analysis_utils.py | 51 ++-
sdks/python/tox.ini | 4 +-
.../en/documentation/runtime/environments.md | 8 +-
33 files changed, 1492 insertions(+), 463 deletions(-)
copy .github/workflows/{beam_PreCommit_Java_PVR_Flink_Docker.yml =>
beam_PreCommit_Java_PVR_Flink_Batch.yml} (71%)
copy .github/workflows/{beam_PreCommit_Portable_Python.yml =>
beam_PreCommit_Python_PVR_Flink.yml} (63%)
copy .github/workflows/{beam_PostCommit_Go_Dataflow_ARM.yml =>
beam_Release_Python_NightlySnapshot.yml} (60%)
delete mode 100644
.test-infra/jenkins/job_PostCommit_BeamMetrics_Publish.groovy
delete mode 100644
.test-infra/jenkins/job_Release_Python_NightlySnapshot.groovy
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/grpcclient/GrpcDeadlineClientInterceptor.java
create mode 100644 sdks/go/container/tools/buffered_logging.go
create mode 100644 sdks/go/container/tools/buffered_logging_test.go
create mode 100644 sdks/python/apache_beam/runners/trivial_runner.py
create mode 100644 sdks/python/apache_beam/runners/trivial_runner_test.py
