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)