You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mi...@apache.org on 2019/09/06 22:10:49 UTC

[beam] branch master updated (062dec2 -> 4a6dc28)

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(-)