afedulov commented on a change in pull request #15054:
URL: https://github.com/apache/flink/pull/15054#discussion_r603336749
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
##########
@@ -497,6 +505,32 @@ private void stopTaskExecutorServices() throws Exception {
// RPC methods
// ======================================================================
+ @Override
+ public CompletableFuture<TaskThreadInfoResponse> requestThreadInfoSamples(
+ final ExecutionAttemptID taskExecutionAttemptId,
+ final ThreadInfoSamplesRequest requestParams,
+ final Time timeout) {
+
+ final Task task = taskSlotTable.getTask(taskExecutionAttemptId);
+ if (task == null) {
+ return FutureUtils.completedExceptionally(
+ new IllegalStateException(
+ String.format(
+ "Cannot sample task %s. "
+ + "Task is not known to the task
manager.",
Review comment:
Do I get it correctly that this comment is primarily related to how to
best handle this exception when it bubbles up to the `OperatorTracker` rather
then to the fact that it is thrown here?
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
