mirror of https://github.com/apache/druid.git
fix groupBy deserialization
This commit is contained in:
parent
72eb64a40c
commit
3261fd879a
|
@ -355,7 +355,7 @@ public class GroupByQueryQueryToolChest extends QueryToolChest<Row, GroupByQuery
|
||||||
|
|
||||||
while (aggsIter.hasNext()) {
|
while (aggsIter.hasNext()) {
|
||||||
final AggregatorFactory factory = aggsIter.next();
|
final AggregatorFactory factory = aggsIter.next();
|
||||||
Object agg = event.remove(factory.getName());
|
Object agg = event.get(factory.getName());
|
||||||
if (agg != null) {
|
if (agg != null) {
|
||||||
event.put(factory.getName(), factory.deserialize(agg));
|
event.put(factory.getName(), factory.deserialize(agg));
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue