You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/11/17 16:45:38 UTC
[flink] 02/02: [FLINK-24409][kafka] Log PendingRecords metrics name if record lag collection fails
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 <fa...@ververica.com>
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;
}