This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4d42c64 [FLINK-26517][runtime] Normalize the decided parallelism to
power of 2 when using adaptive batch scheduler.
add 29be5ce [FLINK-26492][metric] deprecate numRecordsOutErrorsCounter,
replace it with umRecordsSendErrorsCounter
add 77cfb9b [FLINK-26492][kafka] deprecate numRecordsOutErrorsCounter,
replace it with umRecordsSendErrorsCounter
add 36539b0 [FLINK-26492][firehose] deprecate numRecordsOutErrorsCounter,
replace it with umRecordsSendErrorsCounter
add 4f233f8 [FLINK-26492][kinesis] deprecate numRecordsOutErrorsCounter,
replace it with umRecordsSendErrorsCounter
No new revisions were added by this update.
Summary of changes:
docs/content/docs/ops/metrics.md | 10 +++++++++-
.../connector/firehose/sink/KinesisFirehoseSinkWriter.java | 8 +++++++-
.../firehose/sink/KinesisFirehoseSinkWriterTest.java | 1 +
.../connector/kinesis/sink/KinesisStreamsSinkWriter.java | 7 ++++++-
.../org/apache/flink/connector/kafka/sink/KafkaWriter.java | 6 +++++-
.../apache/flink/connector/kafka/sink/KafkaWriterITCase.java | 7 +++++++
.../apache/flink/metrics/groups/SinkWriterMetricGroup.java | 9 +++++++--
.../java/org/apache/flink/runtime/metrics/MetricNames.java | 4 +++-
.../runtime/metrics/groups/InternalSinkWriterMetricGroup.java | 11 ++++++++++-
.../flink/test/streaming/runtime/SinkMetricsITCase.java | 4 ++++
10 files changed, 59 insertions(+), 8 deletions(-)
