[FLINK-34550] attempted task still report metric of currentEmitEventTimeLag

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.17.1
• Component/s: Connectors / Kafka
• Labels: streamsource

Environment

flink version:1.17.1  

kafka-connector：1.17.1

• Assignee: Unassigned
• Reporter: siwei.gao
• Created: 29/Feb/24 13:52
• Updated: 01/Mar/24 01:51

Description

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.

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.