This is an automated email from the ASF dual-hosted git repository.
scwhittle pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 5b03c0cbd51 Use ThreadLocalRandom instead of Random in
OutputObjectAndByteCounter to reduce contention (#33737)
add b8bd935521e [Dataflow Streaming] Optimizing work submit loop (#33736)
No new revisions were added by this update.
Summary of changes:
.../runners/dataflow/worker/streaming/Work.java | 22 ++++++++++++-------
.../harness/SingleSourceWorkerHarness.java | 4 ++--
.../worker/util/common/worker/OutputReceiver.java | 3 ++-
.../client/grpc/GetWorkResponseChunkAssembler.java | 6 ++++--
.../client/grpc/GetWorkTimingInfosTracker.java | 14 ++++++------
.../worker/windmill/work/WorkItemReceiver.java | 5 +++--
.../worker/windmill/work/WorkItemScheduler.java | 4 ++--
.../work/processing/StreamingWorkScheduler.java | 25 +++++++++++++---------
.../dataflow/worker/FakeWindmillServer.java | 4 ++--
.../worker/StreamingDataflowWorkerTest.java | 6 ++----
.../worker/StreamingModeExecutionContextTest.java | 4 +---
.../dataflow/worker/WorkerCustomSourcesTest.java | 6 ++----
.../worker/streaming/ActiveWorkStateTest.java | 6 ++----
.../streaming/ComputationStateCacheTest.java | 4 +---
.../worker/util/BoundedQueueExecutorTest.java | 4 +---
.../StreamingApplianceWorkCommitterTest.java | 4 +---
.../commits/StreamingEngineWorkCommitterTest.java | 3 +--
.../client/grpc/GrpcWindmillServerTest.java | 11 +++++-----
.../failures/WorkFailureProcessorTest.java | 4 +---
.../work/refresh/ActiveWorkRefresherTest.java | 4 +---
20 files changed, 69 insertions(+), 74 deletions(-)
