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 35732ce8083 Support use staged harness for Dataflow runner v2 job
(#33508)
add d7c56914f80 [Dataflow Streaming] Support to receive multiple work
items in a single StreamingGetWorkResponseChunk (#33512)
No new revisions were added by this update.
Summary of changes:
.../options/DataflowStreamingPipelineOptions.java | 5 +
.../dataflow/worker/StreamingDataflowWorker.java | 3 +-
.../client/grpc/GetWorkResponseChunkAssembler.java | 24 +++-
.../client/grpc/GrpcDirectGetWorkStream.java | 10 +-
.../windmill/client/grpc/GrpcGetWorkStream.java | 24 ++--
.../windmill/client/grpc/GrpcWindmillServer.java | 2 +
.../client/grpc/GrpcWindmillStreamFactory.java | 10 ++
.../FanOutStreamingEngineWorkerHarnessTest.java | 2 +-
.../client/grpc/GrpcDirectGetWorkStreamTest.java | 138 ++++++++++++++++++--
.../client/grpc/GrpcWindmillServerTest.java | 139 ++++++++++++++++++++-
.../worker/windmill/src/main/proto/windmill.proto | 6 +-
11 files changed, 332 insertions(+), 31 deletions(-)
