(boolean verbose)
| 110 | } |
| 111 | |
| 112 | @Override |
| 113 | public boolean waitForCompletion(boolean verbose) throws IOException, |
| 114 | InterruptedException, ClassNotFoundException { |
| 115 | boolean succeeded = super.waitForCompletion(verbose); |
| 116 | if (!succeeded) { |
| 117 | // check if we want to fail whenever a job fails. (expert setting) |
| 118 | if (getConfiguration().getBoolean("fail.on.job.failure", true)) { |
| 119 | throw new RuntimeException("job failed: " + "name=" + getJobName() |
| 120 | + ", jobid=" + getJobID()); |
| 121 | } |
| 122 | } |
| 123 | return succeeded; |
| 124 | } |
| 125 | |
| 126 | public static boolean shouldProcess(CharSequence mark, Utf8 batchId) { |
| 127 | if (mark == null) { |
no test coverage detected