This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit a8612788cb77a8b9d79bfbe44321c941d38322e7 Merge: fb0353e ea2a3f6 Author: Thomas Weise <[email protected]> AuthorDate: Fri Dec 27 19:08:19 2019 -0800 Merge pull request #10415: [BEAM-8962] Report Flink metric accumulator only when pipeline ends .../beam/runners/flink/FlinkPipelineOptions.java | 9 -- .../flink/metrics/FlinkMetricContainer.java | 49 +++++----- .../runners/flink/metrics/MetricsAccumulator.java | 6 +- .../translation/functions/FlinkDoFnFunction.java | 10 +- .../functions/FlinkExecutableStageFunction.java | 9 +- .../functions/FlinkStatefulDoFnFunction.java | 11 +-- .../translation/wrappers/SourceInputFormat.java | 8 +- .../wrappers/streaming/DoFnOperator.java | 4 +- .../streaming/io/UnboundedSourceWrapper.java | 9 +- .../runners/flink/FlinkPipelineOptionsTest.java | 1 - .../flink/metrics/FlinkMetricContainerTest.java | 14 +-- .../functions/FlinkDoFnFunctionTest.java | 106 +++++++++++++++++++++ .../FlinkExecutableStageFunctionTest.java | 16 ++++ .../functions/FlinkStatefulDoFnFunctionTest.java | 106 +++++++++++++++++++++ .../wrappers/SourceInputFormatTest.java | 64 +++++++++++++ .../wrappers/streaming/DoFnOperatorTest.java | 77 +++++++++------ .../streaming/io/UnboundedSourceWrapperTest.java | 30 ++++++ .../src/_includes/flink_java_pipeline_options.html | 5 - .../_includes/flink_python_pipeline_options.html | 5 - 19 files changed, 426 insertions(+), 113 deletions(-)
