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 2025/09/03 03:57:03 UTC
(beam) branch nightly-refs/heads/master updated (2ab70ffabea -> 35969b34a37)

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 2ab70ffabea Upgrade Errorprone to 2.31.0 (#35684)
     add 266de262f0e Bump cloud.google.com/go/bigquery from 1.69.0 to 1.70.0 in /sdks (#36024)
     add f69fd7230b4 Exit the poll loop in ReadFromKafkaDoFn after consumerPollingTimeout has elapsed (#36029)
     add a4ad5cd8b4e refactor(build): update changelog formatting in gradle task (#36021)
     add 9f3b160c100 Add validation to check for non-ints from partitionfns (#35881)
     add 523d833381a Cache deterministic types (#36032)
     add f725e85e48f Update CHANGES.md (#36033)
     add 4289ea20a8d Allow stateful exception handling (#35965)
     add 7d6de9aa927 [Prism] Fix two kinds of errors when using json log format. (#36020)
     add 35969b34a37 Introduce more abstract handling of throttling signaling (#35984)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         | 155 ++++++++++-----------
 build.gradle.kts                                   | 127 +++++++++++++++++
 contributor-docs/code-change-guide.md              |  13 ++
 sdks/go.mod                                        |   2 +-
 sdks/go.sum                                        |   4 +-
 .../prism/internal/engine/elementmanager.go        |  23 ++-
 .../beam/runners/prism/internal/environments.go    |   8 +-
 sdks/go/pkg/beam/runners/prism/internal/execute.go |   6 +-
 sdks/go/pkg/beam/runners/prism/internal/stage.go   |  13 ++
 .../beam/sdk/io/kafka/ReadFromKafkaDoFn.java       |  20 ++-
 sdks/python/apache_beam/coders/coder_impl.pxd      |   2 +
 sdks/python/apache_beam/coders/coder_impl.py       |  15 +-
 .../io/components/adaptive_throttler.py            |  92 ++++++++++++
 sdks/python/apache_beam/ml/inference/base.py       |  43 +++---
 .../apache_beam/runners/portability/job_server.py  |   7 +-
 .../runners/portability/prism_runner.py            |  13 +-
 .../apache_beam/tools/coders_microbenchmark.py     |  10 ++
 sdks/python/apache_beam/transforms/core.py         |  68 ++++++++-
 sdks/python/apache_beam/transforms/core_test.py    |  79 +++++++++++
 sdks/python/apache_beam/transforms/external.py     |   3 +-
 sdks/python/apache_beam/utils/subprocess_server.py |  23 ++-
 21 files changed, 585 insertions(+), 141 deletions(-)