THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Name | Type | Unit | Description |
numBytesIn | Counter | Bytes | The total number of input bytes since the source started |
numBytesInPerSecnumBytesInPerSecond | Meter | Bytes/Sec | The input bytes per second |
numRecordsIn | Counter | Records | (Existing operator metric) The total number of input records since the source started |
numRecordsInPerSecnumRecordsInPerSecond | Meter | Records/Sec | (Existing operator metric) The input records per second |
| numRecordsInErrors | Counter | Records | The total number of record that failed to consume |
| currentFetchLatency | Gauge | ms | The latency occurred before Flink fetched the record. This metric is an instantaneous value recorded for the last processed record. This metric is provided because latency histogram could be expensive. The instantaneous latency value is usually a good enough indication of the latency. fetchLatency = FetchTime - EventTime |
| currentLatency | Gauge | ms | The latency occurred before the record is emitted by the source connector. This metric is an instantaneous value recorded for the last processed record. This metric is provided because latency histogram could be expensive. The instantaneous latency value is usually a good enough indication of the latency. latency = EmitTime - EventTime |
idleTime | Gauge | ms | The time in milliseconds that the source has not processed any record. idleTime = CurrentTime - LastRecordProcessTime |
| pendingBytes | Gauge | Bytes | The number of bytes that have not been fetched by the source. e.g. the remaining bytes in a file after the file descriptor reading position. |
| pendingRecords | Gauge | Records | The number of records that have not been fetched by the source. e.g. the available records after the consumer offset in a Kafka partition. |
...
Name | Type | Unit | Description |
numBytesOut | Counter | Bytes | The total number of output bytes since the source started |
numBytesOutPerSecnumBytesOutPerSecond | Meter | Bytes/Sec | The output bytes per second |
numRecordsOut | Counter | Records | (Existing operator metric) The total number of output records since the source started |
numRecordsOutPerSecnumRecordsOutPerSecond | Meter | Records/Sec | (Existing operator metric) The output records per second |
| numRecordsOutErrors | Counter | Record | The total number of records failed to send |
| currentSendTime | Gauge | ms | The time it takes to send the last record. This metric is an instantaneous value recorded for the last processed record. |
...