This is an automated email from the ASF dual-hosted git repository.
mikhail pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 062dec2 Add non-terminal option for go harness worker hook
add 4a6dc28 [BEAM-7969] Fix doublecount on Cross SDK boundary GRPC
PCollections in streaming jobs. (#9494)
No new revisions were added by this update.
Summary of changes:
.../worker/fn/control/BeamFnMapTaskExecutor.java | 21 +++++-
...ntMonitoringInfoToCounterUpdateTransformer.java | 3 +-
.../control/RegisterAndProcessBundleOperation.java | 84 ++++++++++++++++++++++
...low_exercise_streaming_metrics_pipeline_test.py | 15 ++++
4 files changed, 118 insertions(+), 5 deletions(-)
