You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by bh...@apache.org on 2022/02/28 18:43:42 UTC

[beam] branch release-2.37.0 updated (39895d1 -> 503268b)

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

bhulette pushed a change to branch release-2.37.0
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 39895d1  [cherry-pick][release-2.37.0][BEAM-12164]: fix bug when retrieving either string or json #16890 (#16900)
     add 503268b  [release-2.37.0] Fix BoundedQueueExecutor and StreamingDataflowWorker to actually limit memory from windmill (#16901) (#16941)

No new revisions were added by this update.

Summary of changes:
 .../options/DataflowPipelineDebugOptions.java      |  24 ++++
 .../dataflow/worker/StreamingDataflowWorker.java   |  64 ++++-----
 .../dataflow/worker/util/BoundedQueueExecutor.java | 148 ++++++++++++++++-----
 .../worker/StreamingDataflowWorkerTest.java        |  16 +--
 4 files changed, 171 insertions(+), 81 deletions(-)