+ Optional<RemoteFile> logFile = client.getJobResults(job.getJobId()).stream()
+ .filter(f -> f.getLabel() == "log").findFirst();
+ if (logFile.isPresent())
+ {
+ InputStream stream = logFile.get().getContent();
+ long nextChunk = stream.skip(job.getNextChunk());
+ job.setnextChunk(nextChunk + appendJobStatus(job, stream));
+ }
+ if (failedStates.contains(job.getJobState()))
+ {
+ Optional<RemoteFile> errLogFile = client.getJobResults(job.getJobId()).stream()
+ .filter(f -> f.getLabel() == "error-log").findFirst();
+ if (errLogFile.isPresent())
+ {
+ appendJobStatus(job, errLogFile.get().getContent());
+ }
+ }