2019-02-22 16:03:35

docs/1.7-SNAPSHOT/120.md

@@ -800,7 +800,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | **Job-/TaskManager** | Status.JVM.CPU | 加载 | JVM最近的CPU使用情况。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 时间 | JVM使用的CPU时间。 | 测量 |
 
 ### 内存
@@ -808,7 +807,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | **Job-/TaskManager** | Status.JVM.Memory | Heap.Used | 当前使用的堆内存量（以字节为单位）。 | 测量 |
-| --- | --- | --- | --- | --- |
 | Heap.Committed | 保证可供JVM使用的堆内存量（以字节为单位）。 | 测量 |
 | Heap.Max | 可用于内存管理的最大堆内存量（以字节为单位）。 | 测量 |
 | NonHeap.Used | 当前使用的非堆内存量（以字节为单位）。 | 测量 |
@@ -826,14 +824,12 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | **Job-/TaskManager** | Status.JVM.Threads | 计数 | 活动线程总数。 | 测量 |
-| --- | --- | --- | --- | --- |
 
 ### 垃圾收集
 
 | 范围 | 中缀 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | **Job-/TaskManager** | Status.JVM.GarbageCollector | <GarbageCollector> .Count之间 | 已发生的集合总数。 | 测量 |
-| --- | --- | --- | --- | --- |
 | <GarbageCollector>。时间 | 执行垃圾收集所花费的总时间。 | 测量 |
 
 ### 类加载器
@@ -841,7 +837,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | **Job-/TaskManager** | Status.JVM.ClassLoader | ClassesLoaded | 自JVM启动以来加载的类总数。 | 测量 |
-| --- | --- | --- | --- | --- |
 | ClassesUnloaded | 自JVM启动以来卸载的类总数。 | 测量 |
 
 ### 网络
@@ -849,10 +844,8 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | **TaskManager** | Status.Network | AvailableMemorySegments | 未使用的内存段数。 | 测量 |
-| --- | --- | --- | --- | --- |
 | TotalMemorySegments | 分配的内存段数。 | 测量 |
 | Task | buffers | inputQueueLength | 排队的输入缓冲区数。 | 测量 |
-| --- | --- | --- | --- | --- |
 | outputQueueLength | 排队输出缓冲区的数量。 | 测量 |
 | inPoolUsage | 估计输入缓冲区的使用情况。 | 测量 |
 | outPoolUsage | 估计输出缓冲区的使用情况。 | 测量 |
@@ -866,7 +859,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- |
 | **JobManager** | numRegisteredTaskManagers | 注册任务管理员的数量。 | 测量 |
-| --- | --- | --- | --- |
 | numRunningJobs | 正在运行的作业数量。 | 测量 |
 | taskSlotsAvailable | 可用任务槽的数量。 | 测量 |
 | taskSlotsTotal | 任务槽的总数。 | 测量 |
@@ -876,7 +868,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- |
 | **Job (only available on JobManager)** | restartingTime | 重新启动作业所花费的时间，或当前重新启动的持续时间（以毫秒为单位）。 | 测量 |
-| --- | --- | --- | --- |
 | uptime | 作业运行的时间不间断。对于已完成的作业，返回-1（以毫秒为单位）。 | 测量 |
 | downtime | 对于当前处于故障/恢复状态的作业，在此中断期间经过的时间。对于正在运行的作业返回0，对于已完成的作业返回-1（以毫秒为单位）。 | 测量 |
 | fullRestarts | 自提交此作业以来完全重新启动的总次数。 | 测量 |
@@ -886,7 +877,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- |
 | **Job (only available on JobManager)** | lastCheckpointDuration | 完成最后一个检查点所花费的时间（以毫秒为单位）。 | 测量 |
-| --- | --- | --- | --- |
 | lastCheckpointSize | 最后一个检查点的总大小（以字节为单位）。 | 测量 |
 | lastCheckpointExternalPath | 存储最后一个外部检查点的路径。 | 测量 |
 | lastCheckpointRestoreTimestamp | 在协调器上恢复最后一个检查点时的时间戳（以毫秒为单位）。 | 测量 |
@@ -896,16 +886,13 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | numberOfFailedCheckpoints | 失败检查点的数量。 | 测量 |
 | totalNumberOfCheckpoints | 总检查点的数量（正在进行，已完成，失败）。 | 测量 |
 | Task | checkpointAlignmentTime | 最后一次屏障对齐完成所花费的时间（以纳秒为单位），或当前对齐到目前为止所用的时间（以纳秒为单位）。 | 测量 |
-| --- | --- | --- | --- |
 
 ### IO
 
 | 范围 | 度量 | 描述 | 类型 |
 | --- | --- | --- | --- |
 | **Job (only available on TaskManager)** | <SOURCE_ID> <source_subtask_index> <operator_id> <operator_subtask_index> .latency | 从给定源子任务到算子子任务的延迟分布（以毫秒为单位）。 | 直方图 |
-| --- | --- | --- | --- |
 | **任务** | numBytesInLocal | 此任务从本地源读取的总字节数。 | 计数器 |
-| --- | --- | --- | --- |
 | numBytesInLocalPerSecond | 此任务每秒从本地源读取的字节数。 | 仪表 |
 | numBytesInRemote | 此任务从远程源读取的总字节数。 | 计数器 |
 | numBytesInRemotePerSecond | 此任务每秒从远程源读取的字节数。 | 仪表 |
@@ -918,14 +905,12 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | numBuffersOut | 此任务已发出的网络缓冲区总数。 | 计数器 |
 | numBuffersOutPerSecond | 此任务每秒发出的网络缓冲区数。 | 仪表 |
 | **任务/算子** | numRecordsIn | 此 算子/任务已收到的记录总数。 | 计数器 |
-| --- | --- | --- | --- |
 | numRecordsInPerSecond | 此 算子/任务每秒接收的记录数。 | 仪表 |
 | numRecordsOut | 此 算子/任务已发出的记录总数。 | 计数器 |
 | numRecordsOutPerSecond | 此 算子/任务每秒发送的记录数。 | 仪表 |
 | numLateRecordsDropped | 此算子/任务因迟到而丢失的记录数。 | 计数器 |
 | currentInputWatermark | 此 算子/任务收到的​​最后一个水印（以毫秒为单位）。**注意：**对于具有2个输入的算子/任务，这是最后收到的水印的最小值。 | 测量 |
 | **算子** | currentInput1Watermark | 此 算子在其第一个输入（毫秒）中收到的最后一个水印。**注意：**仅适用于具有2个输入的算子。 | 测量 |
-| --- | --- | --- | --- |
 | currentInput2Watermark | 此 算子在其第二个输入中接收的最后一个水印（以毫秒为单位）。**注意：**仅适用于具有2个输入的算子。 | 测量 |
 | currentOutputWatermark | 此 算子发出的最后一个水印（以毫秒为单位）。 | 测量 |
 | numSplitsProcessed | 此数据源已处理的InputSplits总数（如果 算子是数据源）。 | 测量 |
@@ -937,36 +922,23 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 度量 | 用户变量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | 算子 | commitsSucceeded | N / A | 如果启用了偏移提交并且启用了检查点，则成功向Kafka提交的偏移提交总数。 | 计数器 |
-| --- | --- | --- | --- | --- |
 | 算子 | commitsFailed | N / A | 如果启用了偏移提交并且启用了检查点，则Kafka的偏移提交失败总数。请注意，将偏移量提交回Kafka只是暴露消费者进度的一种方法，因此提交失败不会影响Flink的检查点分区偏移的完整性。 | 计数器 |
-| --- | --- | --- | --- | --- |
 | 算子 | committedOffsets | Topic，分区 | 对于每个分区，最后成功提交到Kafka的偏移量。可以通过主题名称和分区ID指定特定分区的度量标准。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | currentOffsets | Topic，分区 | 消费者对每个分区的当前读取偏移量。可以通过主题名称和分区ID指定特定分区的度量标准。 | 测量 |
-| --- | --- | --- | --- | --- |
 
 #### Kinesis连接器
 
 | 范围 | 度量 | 用户变量 | 描述 | 类型 |
 | --- | --- | --- | --- | --- |
 | 算子 | millisBehindLatest | stream，shardId | 对于每个Kinesis分片，消费者在流的头部后面的毫秒数，表示消费者当前时间落后多少。可以通过流名称和分片标识指定特定分片的度量标准。值为0表示记录处理被捕获，此时没有要处理的新记录。值-1表示该度量标准尚未报告。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | sleepTimeMillis | stream，shardId | 消费者在从Kinesis获取记录之前花费的毫秒数。可以通过流名称和分片标识指定特定分片的度量标准。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | maxNumberOfRecordsPerFetch | stream，shardId | 消费者在单个getRecords调用Kinesis时请求的最大记录数。如果ConsumerConfigConstants.SHARD_USE_ADAPTIVE_READS设置为true，则自适应地计算此值以最大化Kinesis的2 Mbps读取限制。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | numberOfAggregatedRecordsPerFetch | stream，shardId | 消费者在单个getRecords调用Kinesis时获取的聚合Kinesis记录数。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | numberOfDeggregatedRecordsPerFetch | stream，shardId | 消费者在单个getRecords调用Kinesis时获取的分解Kinesis记录的数量。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | averageRecordSizeBytes | stream，shardId | Kinesis记录的平均大小（以字节为单位），由消费者在单个getRecords调用中获取。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | runLoopTimeNanos | stream，shardId | 消费者在运行循环中花费的实际时间（以纳秒为单位）。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | loopFrequencyHz | stream，shardId | 一秒钟内调用getRecords的次数。 | 测量 |
-| --- | --- | --- | --- | --- |
 | 算子 | bytesRequestedPerFetch | stream，shardId | 在一次调用getRecords中请求的字节数（2 Mbps / loopFrequencyHz）。 | 测量 |
-| --- | --- | --- | --- | --- |
 
 ### 系统资源
 
@@ -988,7 +960,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 |
 | --- | --- | --- | --- |
 | **Job-/TaskManager** | System.CPU | 用法 | 机器上CPU使用率的总体百分比。 |
-| --- | --- | --- | --- |
 | 闲 | 机器上CPU空闲使用率的百分比。 |
 | SYS | 计算机上系统CPU使用率的百分比。 |
 | 用户 | 计算机上用户CPU使用率的百分比。 |
@@ -1006,7 +977,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 |
 | --- | --- | --- | --- |
 | **Job-/TaskManager** | System.Memory | 可得到 | 可用内存字节数 |
-| --- | --- | --- | --- |
 | 总 | 总内存（字节） |
 | System.Swap | 用过的 | 使用的交换字节 |
 | 总 | 总交换字节数 |
@@ -1016,7 +986,6 @@ metrics.reporter.slf4j.interval: 60 SECONDS
 | 范围 | 中缀 | 度量 | 描述 |
 | --- | --- | --- | --- |
 | **Job-/TaskManager** | System.Network.INTERFACE_NAME | ReceiveRate | 平均接收速率，以每秒字节数为单位 |
-| --- | --- | --- | --- |
 | SendRate | 平均发送速率，以字节/秒为单位 |
 
 ## 延迟跟踪