This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b69c81a [BEAM-6907] Reuse Python tarball in tox & dataflow
integration tests
add 936110f [BEAM-7820] Add basic hot key detection logging in Worker.
(#9270)
No new revisions were added by this update.
Summary of changes:
.../worker/DataflowWorkProgressUpdater.java | 55 +++--------
.../beam/runners/dataflow/worker/HotKeyLogger.java | 77 +++++++++++++++
.../dataflow/worker/StreamingDataflowWorker.java | 23 ++++-
.../worker/DataflowWorkProgressUpdaterTest.java | 71 ++++----------
.../runners/dataflow/worker/HotKeyLoggerTest.java | 104 +++++++++++++++++++++
.../worker/StreamingDataflowWorkerTest.java | 15 ++-
6 files changed, 243 insertions(+), 102 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/HotKeyLogger.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/HotKeyLoggerTest.java
