(String jobId, Exception e)
| 478 | } |
| 479 | |
| 480 | @Private |
| 481 | public void setBackendException(String jobId, Exception e) { |
| 482 | if (e instanceof PigException) { |
| 483 | LOG.error("ERROR " + ((PigException)e).getErrorCode() + ": " |
| 484 | + e.getLocalizedMessage()); |
| 485 | } else if (e != null) { |
| 486 | LOG.error("ERROR: " + e.getLocalizedMessage()); |
| 487 | } |
| 488 | |
| 489 | if (jobId == null || e == null) { |
| 490 | LOG.debug("unable to set backend exception"); |
| 491 | return; |
| 492 | } |
| 493 | Iterator<JobStats> iter = jobPlan.iterator(); |
| 494 | while (iter.hasNext()) { |
| 495 | JobStats js = iter.next(); |
| 496 | if (jobId.equals(js.getJobId())) { |
| 497 | js.setBackendException(e); |
| 498 | break; |
| 499 | } |
| 500 | } |
| 501 | } |
| 502 | |
| 503 | @Private |
| 504 | public PigContext getPigContext() { |
nothing calls this directly
no test coverage detected