flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zhijiang" <wangzhijiang...@aliyun.com>
Subject Re: The mapping relationship between Checkpoint subtask id and Task subtask id
Date Fri, 14 Feb 2020 03:14:27 GMT
If the id is not consistent in different parts, maybe it is worth creating a jira ticket for
better improving the user experience.
If anyone wants to work on it, please ping me then I can give a hand.

Best,
Zhijiang
------------------------------------------------------------------
From:Yun Tang <myasuka@live.com>
Send Time:2020 Feb. 14 (Fri.) 10:52
To:杨东晓 <laolang113@gmail.com>; user <user@flink.apache.org>
Subject:Re: The mapping relationship between Checkpoint subtask id and Task subtask id

 Hi

 Yes, you are right. Just simply use checkpoint subtask_id -1 would find the corresponding
task subtask_id.

 Best
 Yun Tang

From: 杨东晓 <laolang113@gmail.com>
Sent: Friday, February 14, 2020 10:11
To: user <user@flink.apache.org>
Subject: The mapping relationship between Checkpoint subtask id and Task subtask id
Hi, I'm trying to figure out the different end2end duration for each subtask id in checkpoint.

In flink web ui I noticed  for job task subtask id it start from 0 and for checkpoint  subtask
id it start from number 1,.
How can I find out which checkpoint subtask id belongs to which job task subtask id, just
simply use checkpoint subtask ID -1 will be ok?
Thanks

Mime
View raw message