This is an automated email from the ASF dual-hosted git repository.

mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 8ec5889  Merge pull request #10382: [BEAM-8967] Declare JSR305 
dependency as 'shadow'
     add b74b91d  [BEAM-8962] Add option to disable the metric container 
accumulator
     add 15a3eb0  Merge pull request #10381: [BEAM-8962] Add option to disable 
the metric container accumulator

No new revisions were added by this update.

Summary of changes:
 .../beam/runners/flink/FlinkPipelineOptions.java   |  9 +++++++
 .../flink/metrics/FlinkMetricContainer.java        | 30 ++++++++++++++--------
 .../runners/flink/metrics/MetricsAccumulator.java  |  1 +
 .../translation/functions/FlinkDoFnFunction.java   |  8 ++++--
 .../functions/FlinkExecutableStageFunction.java    |  8 +++---
 .../functions/FlinkStatefulDoFnFunction.java       |  8 ++++--
 .../translation/wrappers/SourceInputFormat.java    |  6 ++++-
 .../wrappers/streaming/DoFnOperator.java           |  3 ++-
 .../streaming/io/UnboundedSourceWrapper.java       |  4 ++-
 .../runners/flink/FlinkPipelineOptionsTest.java    |  2 ++
 .../flink/metrics/FlinkMetricContainerTest.java    | 25 ++++++++++++------
 11 files changed, 76 insertions(+), 28 deletions(-)

Reply via email to