Skip to content

Metrics DataStreamAPI #14

@mzitnik

Description

@mzitnik

Collect metrics from the Flink context like SinkWriterMetricGroup metricGroup = context.metricGroup();

There are four standard metrics

  • NumRecordsOutErrorsCounter
  • NumRecordsSendErrorsCounter
  • NumRecordsSendCounter
  • NumBytesSendCounter

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions