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(-)
