xintongsong commented on code in PR #21447:
URL: https://github.com/apache/flink/pull/21447#discussion_r1051736030
##########
flink-runtime/src/main/java/org/apache/flink/runtime/messages/ThreadInfoSample.java:
##########
@@ -32,25 +36,33 @@
*/
public class ThreadInfoSample implements Serializable {
+ private final ExecutionAttemptID executionId;
Review Comment:
I'd suggest to change `TaskThreadInfoResponse` to contain a
`Map<ExecutionAttemptID, ThreadInfoSample>`. This class, as indicated by its
name, is specific for a Flink task thread.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
