in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/PodUtils.java [38:53]
public static boolean isPodReady(final Pod pod) {
if (!PodPhase.RUNNING.equals(PodPhase.getPhase(pod))) {
return false;
}
if (pod == null
|| pod.getStatus() == null
|| pod.getStatus().getConditions() == null
|| pod.getStatus().getConditions().isEmpty()) {
return false;
}
return pod.getStatus().getConditions().parallelStream()
.anyMatch(
condition ->
POD_READY_CONDITION_TYPE.equalsIgnoreCase(condition.getType())
&& Boolean.parseBoolean(condition.getStatus()));
}