[
https://issues.apache.org/jira/browse/FLINK-34550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siwei.gao updated FLINK-34550:
------------------------------
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. !image-2024-03-01-09-51-08-909.png|width=992,height=242!
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|width=973,height=730!
was:
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|width=990,height=237!
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|width=973,height=730!
> 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
> Priority: Major
> Labels: streamsource
> 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,
> image-2024-03-01-09-51-08-909.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-03-01-09-51-08-909.png|width=992,height=242!
> 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|width=973,height=730!
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
