diff --git a/indexing-hadoop/src/main/java/org/apache/druid/indexer/JobHelper.java b/indexing-hadoop/src/main/java/org/apache/druid/indexer/JobHelper.java index 59bc30d179d..da5b9e113a3 100644 --- a/indexing-hadoop/src/main/java/org/apache/druid/indexer/JobHelper.java +++ b/indexing-hadoop/src/main/java/org/apache/druid/indexer/JobHelper.java @@ -490,7 +490,6 @@ public class JobHelper progressable )) { HadoopDruidIndexerConfig.JSON_MAPPER.writeValue(descriptorOut, segment); - descriptorOut.flush(); } } catch (RuntimeException | IOException ex) {