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

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


    from e14c385  Merge pull request #6421 from rangadi/cherrypick
     add ff38674  Metric container should forward only metrics of the stepName
     add ee174ea  Enable to configure latencyTrackingInterval
     add 77bfd11  [BEAM-5385] Flink job server to use REST port from 
--flink-master-url instead of default.
     new 764eef5  Merge pull request #6427: [release-2.7] Cherrypicks for Flink 
Runner

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../beam/runners/flink/FlinkExecutionEnvironments.java   | 16 ++++++++++++++++
 .../apache/beam/runners/flink/FlinkPipelineOptions.java  |  8 ++++++++
 .../flink/metrics/DoFnRunnerWithMetricsUpdate.java       |  2 +-
 .../beam/runners/flink/metrics/FlinkMetricContainer.java |  4 ++--
 .../beam/runners/flink/metrics/ReaderInvocationUtil.java |  4 ++--
 5 files changed, 29 insertions(+), 5 deletions(-)

Reply via email to