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 9c83de646ab Add more tests for S3 filesystem (#24138)
add 48c70cc3074 Merge pull request #23333: Track time on Cloud Dataflow
streaming data reads and export via heartbeats
No new revisions were added by this update.
Summary of changes:
.../dataflow/worker/StreamingDataflowWorker.java | 237 ++--
.../dataflow/worker/WindmillStateReader.java | 25 +-
.../dataflow/worker/FakeWindmillServer.java | 122 ++-
.../worker/StreamingDataflowWorkerTest.java | 1147 ++++++++++++++------
4 files changed, 1100 insertions(+), 431 deletions(-)
