Permalink
Browse files

Adding support for local mode

  • Loading branch information...
1 parent 0974c60 commit 3ff925133ca058e866d496ac936e6f8a0a216b7b Bill Graham committed Apr 4, 2013
@@ -51,7 +51,7 @@ private Event(Type type, T payload) {
this.payload = payload;
}
- private Event(int eventId, long timestamp, Type type, T payload) {
+ public Event(int eventId, long timestamp, Type type, T payload) {
this.id = eventId;
this.timestamp = timestamp;
this.type = type;
@@ -171,6 +171,11 @@ public void jobStartedNotification(String scriptId, String assignedJobId) {
*/
@Override
public void jobFailedNotification(String scriptId, JobStats stats) {
+ if (stats.getJobId() == null) {
+ log.warn("jobId for failed job not found. This should only happen in local mode");
+ return;
+ }
+
DAGNode<PigJob> node = dagNodeJobIdMap.get(stats.getJobId());
if (node == null) {
log.warn("Unrecognized jobId reported for failed job: " + stats.getJobId());

0 comments on commit 3ff9251

Please sign in to comment.