Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1616 from gianm/fix-1545 

Avoid the Hadoop objectMapper in the local IndexTask. Fixes #1545.
This commit is contained in:
Xavier Léauté 2015-08-11 10:54:15 -07:00
parent fadd8a4342 bc0c7dd65d
commit 738da3fdb2
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
indexing-service/src/main/java/io/druid/indexing/common/task/IndexTask.java
View File

@ -39,7 +39,6 @@ import io.druid.data.input.FirehoseFactory;
import io.druid.data.input.InputRow;
import io.druid.data.input.Rows;
import io.druid.granularity.QueryGranularity;
import io.druid.indexer.HadoopDruidIndexerConfig;
import io.druid.indexing.common.TaskLock;
import io.druid.indexing.common.TaskStatus;
import io.druid.indexing.common.TaskToolbox;
@ -267,8 +266,7 @@ public class IndexTask extends AbstractFixedIntervalTask
inputRow
);
collector.add(
hashFunction.hashBytes(HadoopDruidIndexerConfig.jsonMapper.writeValueAsBytes(groupKey))
.asBytes()
hashFunction.hashBytes(jsonMapper.writeValueAsBytes(groupKey)).asBytes()
);
}
}
@ -290,13 +288,7 @@ public class IndexTask extends AbstractFixedIntervalTask
shardSpecs.add(new NoneShardSpec());
} else {
for (int i = 0; i < numberOfShards; ++i) {
shardSpecs.add(
new HashBasedNumberedShardSpec(
i,
numberOfShards,
HadoopDruidIndexerConfig.jsonMapper
)
);
shardSpecs.add(new HashBasedNumberedShardSpec(i, numberOfShards, jsonMapper));
}
}