Fix some unemitted alerts. ()

This commit is contained in:
Gian Merlino 2017-12-06 18:37:02 -08:00 committed by Charles Allen
parent 4365390310
commit 4f5e2b4549
5 changed files with 8 additions and 6 deletions
extensions-contrib/kafka-eight-simpleConsumer/src/main/java/io/druid/firehose/kafka
indexing-service/src/main/java/io/druid/indexing/overlord
server/src/main/java/io/druid

View File

@ -141,7 +141,7 @@ public class KafkaEightSimpleConsumerFirehoseFactory implements
}
log.info("Loaded offset map[%s]", offsetMap);
} else {
log.makeAlert("Unable to cast lastCommit to Map for feed [%s]", feed);
log.makeAlert("Unable to cast lastCommit to Map for feed [%s]", feed).emit();
}
return offsetMap;
}

View File

@ -880,7 +880,7 @@ public class RemoteTaskRunner implements WorkerTaskRunner, TaskLogStreamer
task.getId(),
elapsed,
config.getTaskAssignmentTimeout()
);
).emit();
taskComplete(taskRunnerWorkItem, theZkWorker, TaskStatus.failure(task.getId()));
break;
}

View File

@ -458,7 +458,7 @@ public class SQLMetadataSegmentManager implements MetadataSegmentManager
));
}
catch (IOException e) {
log.makeAlert(e, "Failed to read segment from db.");
log.makeAlert(e, "Failed to read segment from db.").emit();
return null;
}
}

View File

@ -362,7 +362,8 @@ public class RealtimeManager implements QuerySegmentWalker
}
catch (Exception e) {
log.makeAlert(e, "Unknown exception, Ignoring and continuing.")
.addData("inputRow", inputRow);
.addData("inputRow", inputRow)
.emit();
}
try {

View File

@ -376,12 +376,13 @@ public class SegmentLoadDropHandler implements DataSegmentChangeHandler
if (failedSegments.size() > 0) {
log.makeAlert("%,d errors seen while loading segments", failedSegments.size())
.addData("failedSegments", failedSegments);
.addData("failedSegments", failedSegments)
.emit();
}
}
catch (InterruptedException e) {
Thread.currentThread().interrupt();
log.makeAlert(e, "LoadingInterrupted");
log.makeAlert(e, "LoadingInterrupted").emit();
}
backgroundSegmentAnnouncer.finishAnnouncing();