This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit da8ef265e3f78ec71aad43b4f8209884eaf3a860 Author: Fabian Paul <[email protected]> AuthorDate: Wed Nov 17 10:56:21 2021 +0100 [FLINK-24409][kafka] Log PendingRecords metrics name if record lag collection fails --- .../flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java index 94c1cb4..762f9a8 100644 --- a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java +++ b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java @@ -310,7 +310,7 @@ public class KafkaSourceReaderMetrics { "Error when getting Kafka consumer metric \"%s\" " + "for partition \"%s\". " + "Metric \"%s\" may not be reported correctly. ", - RECORDS_LAG, tp, MetricNames.PENDING_BYTES), + RECORDS_LAG, tp, MetricNames.PENDING_RECORDS), e); return null; }
