You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/02/08 18:44:39 UTC
[flink] branch master updated (fd92e56 -> d8a7704)

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

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


    from fd92e56  [FLINK-26006][aws] Close AWS SDK resources
     add 52f4e21  [FLINK-25888][metrics] Move JobStatusMetrics to upper level
     add 6430a0b  [FLINK-25888][metrics] Make JobStatusMetrics logic re-usable
     add 022ea7f  [FLINK-25888][coordination] ExecutionStateUpdateListener provides previous state
     add d8a7704  [FLINK-25888][coordination][metrics] Capture deploymentTime

No new revisions were added by this update.

Summary of changes:
 docs/assets/_custom.scss                           |   6 +-
 docs/content.zh/docs/ops/metrics.md                |  40 +++
 docs/content/docs/ops/metrics.md                   |  40 +++
 .../executiongraph/DefaultExecutionGraph.java      |   7 +-
 .../flink/runtime/executiongraph/Execution.java    |   2 +-
 .../ExecutionStateUpdateListener.java              |   3 +-
 .../runtime/executiongraph/ExecutionVertex.java    |   5 +-
 .../InternalExecutionGraphAccessor.java            |   3 +-
 .../scheduler/DefaultExecutionGraphFactory.java    |   8 +-
 .../runtime/scheduler/ExecutionGraphFactory.java   |   4 +
 .../flink/runtime/scheduler/SchedulerBase.java     | 110 ++------
 .../scheduler/adaptive/AdaptiveScheduler.java      |  13 +-
 .../metrics/DeploymentStateTimeMetrics.java        | 165 ++++++++++++
 .../scheduler/metrics/JobStatusMetrics.java        | 112 +++++++++
 .../scheduler/metrics/MetricsRegistrar.java        |  10 +-
 .../runtime/scheduler/metrics/StateTimeMetric.java |  72 ++++++
 .../TestingDefaultExecutionGraphBuilder.java       |   3 +-
 .../DefaultExecutionGraphFactoryTest.java          |   2 +
 .../flink/runtime/scheduler/SchedulerBaseTest.java | 254 -------------------
 .../runtime/scheduler/adaptive/ExecutingTest.java  |   5 +-
 .../metrics/DeploymentStateTimeMetricsTest.java    | 279 +++++++++++++++++++++
 .../scheduler/metrics/JobStatusMetricsTest.java    | 130 ++++++++++
 .../scheduler/metrics/StateTimeMetricTest.java     | 170 +++++++++++++
 23 files changed, 1077 insertions(+), 366 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/metrics/DeploymentStateTimeMetrics.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/metrics/JobStatusMetrics.java
 copy flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcSystemLoader.java => flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/metrics/MetricsRegistrar.java (77%)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/metrics/StateTimeMetric.java
 delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerBaseTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/metrics/DeploymentStateTimeMetricsTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/metrics/JobStatusMetricsTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/metrics/StateTimeMetricTest.java