|
@@ -118,6 +118,8 @@ public class StreamJob implements Tool {
|
|
|
return submitAndMonitorJob();
|
|
|
}catch (IllegalArgumentException ex) {
|
|
|
//ignore, since log will already be printed
|
|
|
+ // print the log in debug mode.
|
|
|
+ LOG.debug("Error in streaming job", ex);
|
|
|
return 1;
|
|
|
}
|
|
|
}
|
|
@@ -342,13 +344,13 @@ public class StreamJob implements Tool {
|
|
|
return OptionBuilder.withDescription(desc).create(name);
|
|
|
}
|
|
|
|
|
|
- private static void validate(final List<String> values)
|
|
|
+ private void validate(final List<String> values)
|
|
|
throws IllegalArgumentException {
|
|
|
for (String file : values) {
|
|
|
File f = new File(file);
|
|
|
if (!f.canRead()) {
|
|
|
- throw new IllegalArgumentException("File : " + f.getAbsolutePath()
|
|
|
- + " is not readable.");
|
|
|
+ fail("File: " + f.getAbsolutePath()
|
|
|
+ + " does not exist, or is not readable.");
|
|
|
}
|
|
|
}
|
|
|
}
|