RealtimePlumberSchool: Alert and continue on any exception when abandoning segments

This commit is contained in:
Gian Merlino 2013-12-20 11:38:42 -08:00
parent 4d83837e88
commit 837dee1934
1 changed files with 1 additions and 1 deletions

View File

@ -712,7 +712,7 @@ public class RealtimePlumberSchool implements PlumberSchool
handoffCondition.notifyAll();
}
}
catch (IOException e) {
catch (Exception e) {
log.makeAlert(e, "Unable to abandon old segment for dataSource[%s]", schema.getDataSource())
.addData("interval", sink.getInterval())
.emit();