This is an automated email from the ASF dual-hosted git repository. kenn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2a45a5b Merge pull request #16826 from [BEAM-13870] [Playground] Increase test coverage for the cache package add b0899a4 Fix BoundedQueueExecutor and StreamingDataflowWorker to actually limit memory from windmill (#16901) 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(-)