You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by gi...@apache.org on 2018/12/20 23:40:13 UTC
[incubator-druid] branch master updated: fix(indexer): don't flush
closed stream (#6748)
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 <ch...@gmail.com>
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: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org