siwei.gao created FLINK-34550:
---------------------------------
Summary: attempted task still report metric of
currentEmitEventTimeLag
Key: FLINK-34550
URL: https://issues.apache.org/jira/browse/FLINK-34550
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.17.1
Environment: flink version:1.17.1
kafka-connector：1.17.1
Reporter: siwei.gao
Attachments: image-2024-02-29-21-41-01-709.png,
image-2024-02-29-21-43-18-340.png, image-2024-02-29-21-50-55-160.png
Attempted task still report metric of currentEmitEventTimeLag when use
kafka-connector.Attempt_num for reporting indicators of multiple tasks with the
same subtask_index but different task_attempt_num times within the same time
period. !image-2024-02-29-21-43-18-340.png!
Only the metric which tash_attempt_num is 4 should be reported normally.
This condition shows in taskmanager with multiple slots and it's ok when
taskmanager only has one slot.
!image-2024-02-29-21-50-55-160.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
