AHeise commented on a change in pull request #16770:
URL: https://github.com/apache/flink/pull/16770#discussion_r687999644
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java
##########
@@ -75,4 +75,17 @@ public static String currentInputWatermarkName(int index) {
public static final String ESTIMATED_TIME_TO_CONSUME_BUFFERS =
"estimatedTimeToConsumerBuffersMs";
public static final String DEBLOATED_BUFFER_SIZE = "debloatedBufferSize";
+
+ // FLIP-33 source
+ public static final String NUM_RECORDS_IN_ERRORS = "numRecordsInErrors";
+ public static final String CURRENT_FETCH_EVENT_TIME_LAG =
"currentFetchEventTimeLag";
+ public static final String CURRENT_EMIT_EVENT_TIME_LAG =
"currentEmitEventTimeLag";
+ public static final String WATERMARK_LAG = "watermarkLag";
+ public static final String PENDING_RECORDS = "pendingRecords";
+ public static final String PENDING_BYTES = "pendingBytes";
+ public static final String SOURCE_IDLE_TIME = "sourceIdleTime";
+
+ // FLIP-33 sink
+ public static final String NUM_RECORDS_OUT_ERRORS = "numRecordsOutErrors";
Review comment:
Thanks, I will separate.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
