IndexTask: Call plumber.startJob()

2013-12-12 08:46:10 -08:00 · 2013-12-12 08:46:10 -08:00 · b6a52610bc
parent db9b515e71
commit b6a52610bc
1 changed files with 2 additions and 0 deletions
--- 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
@ -334,6 +334,8 @@ public class IndexTask extends AbstractFixedIntervalTask
                                   : toolbox.getConfig().getDefaultRowFlushBoundary();

    try {
+      plumber.startJob();
+
      while (firehose.hasMore()) {
        final InputRow inputRow = firehose.nextRow();