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 2024/02/13 03:48:30 UTC

(beam) branch nightly-refs/heads/master updated (6d10e0f40fd -> fa3249206d0)

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 6d10e0f40fd Fix two flaky tests (#30278)
     add 68873c81042 Update Python Dependencies (#30282)
     add 371576a3b17 Remove unused StreamingDataflowWorker parameter (#30256)
     add 47f777856bf fixed documentation in sdks/python/apache_beam/io/gcp/pubsub.py WriteToPubSub (#30285)
     add fa3249206d0 [JdbcIO] - Adding option for max batch buffering duration (#30259)

No new revisions were added by this update.

Summary of changes:
 .../dataflow/worker/StreamingDataflowWorker.java   |  2 +-
 .../worker/StreamingModeExecutionContext.java      | 23 +++-------
 .../dataflow/worker/counters/NameContext.java      | 29 +++++++++++-
 .../dataflow/worker/streaming/StageInfo.java       |  7 ++-
 .../worker/DataflowExecutionContextTest.java       |  9 ++--
 .../worker/StreamingModeExecutionContextTest.java  | 14 ++----
 .../dataflow/worker/WorkerCustomSourcesTest.java   |  4 +-
 .../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java   | 51 +++++++++++++++++++---
 sdks/python/apache_beam/io/gcp/pubsub.py           |  4 +-
 .../container/py310/base_image_requirements.txt    | 49 +++++++++++----------
 .../container/py311/base_image_requirements.txt    | 49 +++++++++++----------
 .../container/py38/base_image_requirements.txt     | 47 ++++++++++----------
 .../container/py39/base_image_requirements.txt     | 49 +++++++++++----------
 13 files changed, 194 insertions(+), 143 deletions(-)