Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.


...

Page properties

...


Discussion thread

...

...

...

...

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-11576

...

Release1.14


Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

  • A connector implementation does not have to report all the defined metrics. But if a connector reports a metric of the same semantic defined below, the implementation should follow the convention.
  • The following metric convention is not a complete list. More conventional metric will be added over time.
  • The histogram metrics are usually very expensive. Due to its performance impact, we intentionally excluded them in this FLIP. Please see future work section for more details.

...

Sink Metrics

Name

Type

Unit

Description

numBytesOutnumBytesSend

Counter

Bytes

The total number of output bytes since the source started. Count towards the numBytesOut in TaskIOMetricsGroup

Predefined, updated by sink implementations.

numBytesOutPerSecondnumBytesSendPerSecond

Meter

Bytes/Sec

The output bytes per second

Predefined, associated with numBytesOutnumBytesSend.

numRecordsOutnumRecordsSend

Counter

Records

(Existing operator metric) The total number of output records since the source startedThe Sink implementation should reused this existing operator metric instead of creating a new one.sink started

Predefined, updated by sink implementations.

numRecordsOutPerSecondnumRecordsSendPerSecond

Meter

Records/Sec

(Existing operator metric) The output records per secondThe Sink implementation should reused this existing operator metric instead of creating a new one.

Predefined, associated with numBytesOutnumBytesSend.

numRecordsOutErrorsnumRecordsSendErrorsCounterRecord

The total number of records failed to send

Predefined, updated by sink implementations.

currentSendTimeGaugems

The time it takes to send the last record.

This metric is an instantaneous value recorded for the last processed record.

Optional, updated by sink implementations.

...