diff --git a/processing/src/main/java/io/druid/segment/LoggingProgressIndicator.java b/processing/src/main/java/io/druid/segment/LoggingProgressIndicator.java index e86716e8fb7..39b1bcbd976 100644 --- a/processing/src/main/java/io/druid/segment/LoggingProgressIndicator.java +++ b/processing/src/main/java/io/druid/segment/LoggingProgressIndicator.java @@ -76,7 +76,7 @@ public class LoggingProgressIndicator extends BaseProgressIndicator @Override public void progressSection(String section, String message) { - Stopwatch sectionWatch = sections.remove(section); + Stopwatch sectionWatch = sections.get(section); if (sectionWatch == null) { throw new ISE("[%s]: Cannot progress tracker for [%s]. Nothing started.", progressName, section); }