Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Better task log errors.

This commit is contained in:
Gian Merlino 2014-06-02 12:55:17 -07:00
parent 8c73ef648c
commit 8a6384862f
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java
View File

@ -398,7 +398,12 @@ public class OverlordResource
if (stream.isPresent()) { if (stream.isPresent()) {
return Response.ok(stream.get().getInput()).build(); return Response.ok(stream.get().getInput()).build();
} else { } else {
return Response.status(Response.Status.NOT_FOUND).build(); return Response.status(Response.Status.NOT_FOUND)
.entity(
"No log was found for this task. "
+ "The task may not exist, or it may not have begun running yet."
)
.build();
} }
} }
catch (Exception e) { catch (Exception e) {

5
s3-extensions/src/main/java/io/druid/storage/s3/S3TaskLogs.java
View File

@ -97,8 +97,9 @@ public class S3TaskLogs implements TaskLogs
); );
} }
catch (ServiceException e) { catch (ServiceException e) {
if (e.getErrorCode() != null && (e.getErrorCode().equals("NoSuchKey") || e.getErrorCode() if (404 == e.getResponseCode()
.equals("NoSuchBucket"))) { || "NoSuchKey".equals(e.getErrorCode())
|| "NoSuchBucket".equals(e.getErrorCode())) {
return Optional.absent(); return Optional.absent();
} else { } else {
throw new IOException(String.format("Failed to stream logs from: %s", taskKey), e); throw new IOException(String.format("Failed to stream logs from: %s", taskKey), e);