vadimprt commented on issue #17848:
URL: https://github.com/apache/druid/issues/17848#issuecomment-2786410878
```
private TaskStatus getTaskStatus(long duration)
{
TaskStatus taskStatus;
try {
Optional<InputStream> maybeTaskStatusStream =
taskLogs.streamTaskStatus(taskId.getOriginalTaskId());
if (maybeTaskStatusStream.isPresent()) {
taskStatus = mapper.readValue(
IOUtils.toString(maybeTaskStatusStream.get(),
StandardCharsets.UTF_8),
TaskStatus.class
);
} else {
log.info(
"Peon for task [%s] did not push its task status. Check k8s logs
and events for the pod to see what happened.",
taskId
);
taskStatus = TaskStatus.failure(taskId.getOriginalTaskId(), "Peon
did not report status successfully.");
}
}
catch (IOException e) {
log.error(e, "Failed to load task status for task [%s]",
taskId.getOriginalTaskId());
taskStatus = TaskStatus.failure(
taskId.getOriginalTaskId(),
StringUtils.format("error loading status: %s", e.getMessage())
);
}
return taskStatus.withDuration(duration);
}
```
something around
https://github.com/apache/druid/blob/5764183d4e3c3d8267e98eced05858d5524816c9/extensions-contrib/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/KubernetesPeonLifecycle.java
can you please check or instruct how to get more logs around this process?
FYI i am getting this type of behavior/issue since druid version 27.0.0
version 26.0.0 working as expected
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
