This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b99c152 Merge pull request #10397: [BEAM-7970] Touch-up on Go
protobuf generation instructions.
add bac1733 Merge pull request #10311: [BEAM-8810] Detect stuck commits
in StreamingDataflowWorker
No new revisions were added by this update.
Summary of changes:
.../dataflow/worker/StreamingDataflowWorker.java | 309 +++++++++++++--------
.../dataflow/worker/WindmillStateCache.java | 3 +-
.../options/StreamingDataflowWorkerOptions.java | 6 +
.../worker/windmill/GrpcWindmillServer.java | 69 ++---
.../worker/windmill/WindmillServerStub.java | 6 -
.../dataflow/worker/FakeWindmillServer.java | 50 ++--
.../worker/StreamingDataflowWorkerTest.java | 38 ++-
7 files changed, 307 insertions(+), 174 deletions(-)
