diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/IndexTask.java b/indexing-service/src/main/java/io/druid/indexing/common/task/IndexTask.java
index 6e09e46373c..f4265ca1d1f 100644
--- a/indexing-service/src/main/java/io/druid/indexing/common/task/IndexTask.java
+++ b/indexing-service/src/main/java/io/druid/indexing/common/task/IndexTask.java
@@ -368,18 +368,21 @@ public class IndexTask extends AbstractFixedIntervalTask
     }
 
     plumber.persist(firehose.commit());
-    plumber.finishJob();
 
-    // Output metrics
-    log.info(
-        "Task[%s] took in %,d rows (%,d processed, %,d unparseable, %,d thrown away) and output %,d rows",
-        getId(),
-        metrics.processed() + metrics.unparseable() + metrics.thrownAway(),
-        metrics.processed(),
-        metrics.unparseable(),
-        metrics.thrownAway(),
-        metrics.rowOutput()
-    );
+    try {
+      plumber.finishJob();
+    }
+    finally {
+      log.info(
+          "Task[%s] took in %,d rows (%,d processed, %,d unparseable, %,d thrown away) and output %,d rows",
+          getId(),
+          metrics.processed() + metrics.unparseable() + metrics.thrownAway(),
+          metrics.processed(),
+          metrics.unparseable(),
+          metrics.thrownAway(),
+          metrics.rowOutput()
+      );
+    }
 
     // We expect a single segment to have been created.
     return Iterables.getOnlyElement(pushedSegments);