in src/main/java/com/microsoft/azure/spark/tools/job/YarnContainerLogFetcher.java [157:170]
private boolean isYarnAppLogAggregationDone() {
switch (getLogAggregationStatus()) {
case "SUCCEEDED":
case "FAILED":
case "TIME_OUT":
return true;
case "DISABLED":
case "NOT_START":
case "RUNNING":
case "RUNNING_WITH_FAILURE":
default:
return false;
}
}