[ https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851702#comment-16851702 ]
vinoyang commented on FLINK-12683: ---------------------------------- Really? [~klion26] Can you tell have to find their relationship about mapping? We'd better add this information to the log message I provided into "Description". Because we may collect some partial key log into the log system, it will lose the context log messages. > Provide task manager's location information for checkpoint acknowledge > message to improve the checkpoint log message > -------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-12683 > URL: https://issues.apache.org/jira/browse/FLINK-12683 > Project: Flink > Issue Type: Improvement > Components: Runtime / Checkpointing > Reporter: vinoyang > Assignee: vinoyang > Priority: Major > > Currently, the {{AcknowledgeCheckpoint}} does not contain the task manager's > location information. When a task's snapshot task sends an ack message to the > coordinator, we can only log this message: > {code:java} > Received late message for now expired checkpoint attempt 6035 from > ccd88d08bf82245f3466c9480fb5687a of job 775ef8ff0159b071da7804925bbd362f. > {code} > Sometimes we need to get this sub task's location information to do the > further debug work, e.g. stack trace dump. But, without the location > information, It will not help to quickly locate the problem. > -- This message was sent by Atlassian JIRA (v7.6.3#76005)