This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/master by this push:
new bd44e29 fix(indexer): don't flush closed stream (#6748)
bd44e29 is described below
commit bd44e2971f61395844c7463f9c20439f963df842
Author: Christoph Hösler <[email protected]>
AuthorDate: Fri Dec 21 00:40:07 2018 +0100
fix(indexer): don't flush closed stream (#6748)
---
indexing-hadoop/src/main/java/org/apache/druid/indexer/JobHelper.java | 1 -
1 file changed, 1 deletion(-)
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 59bc30d..da5b9e1 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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
