diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java b/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java
index 20a8f7f6bf4..06599dcb272 100644
--- a/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java
+++ b/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java
@@ -398,7 +398,6 @@ public class JobHelper
                 progressable
             )) {
               size.set(zipAndCopyDir(mergedBase, outputStream, progressable));
-              outputStream.flush();
             }
             catch (IOException | RuntimeException exception) {
               log.error(exception, "Exception in retry loop");