Fix conditional.

This commit is contained in:
Gian Merlino 2014-08-08 11:20:36 -07:00
parent f547049929
commit 179170224d
1 changed files with 1 additions and 1 deletions

View File

@ -356,7 +356,7 @@ public class RealtimePlumber implements Plumber
log.makeAlert(e, "Failed to persist merged index[%s]", schema.getDataSource())
.addData("interval", interval)
.emit();
if (!shuttingDown) {
if (shuttingDown) {
// We're trying to shut down, and this segment failed to push. Let's just get rid of it.
// This call will also delete possibly-partially-written files, so we don't need to do it explicitly.
abandonSegment(truncatedTime, sink);