何为Metrics

上报运行指标

为何需要Metrics

可以根据指标进行调整

配置

  1. metrics.reporters: xx,jmx

类型

  • Counter
  • Gauge 最简单的Metric,反应一个值,例如现在使用内存多少。
  • Meter 单位时间内发生事件的次数。频率。
  • Histogram 统计学方面,方差、平均值等。

Metric Group

层级树

Metric Group + Metric Name作为唯一标识

  • TaskManager

    • TaskManagerJob
      • Task
        • TaskIO
        • Operator
          • User defined Group/Metrics
          • OperatorIO
  • JobManager
    • JobManagerJob

自定义Metrics

不是线程安全
继承RichFunction
getRuntimeContext().geMetircGroup().addGroup()
getRuntimeContext().geMetircGroup().count/gauge/meter/histogram()