davidradl commented on code in PR #25999:
URL: https://github.com/apache/flink/pull/25999#discussion_r1918687738
##########
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java:
##########
@@ -84,6 +85,9 @@ public class TemporalRowTimeJoinOperator extends
BaseTwoInputStreamOperatorWithS
private static final String RIGHT_STATE_NAME = "right";
private static final String REGISTERED_TIMER_STATE_NAME = "timer";
private static final String TIMERS_STATE_NAME = "timers";
+ private static final String RIGHT_LATE_ELEMENTS_METRIC_NAME =
"rightNumLateRecords";
+
+ private transient Counter rightNumLateRecords;
Review Comment:
I notice that we already have numLateRecordsDropped metric. Is this
sufficient?
You are proposing a new metric for a subset of operators (ones with 2
inputs) and only for one side, where all the processing is the same for the
left and right sides at the moment.
I wonder if the metric should be when the late record is dropped in line
with the existing metric
We would need documentation to be added for this.
--
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]
