diff options
| author | lifengchao <[email protected]> | 2023-10-16 17:42:48 +0800 |
|---|---|---|
| committer | lifengchao <[email protected]> | 2023-10-16 17:42:48 +0800 |
| commit | 14d06ca0bc382789dbf460f5102aaa33b5e833fd (patch) | |
| tree | 916171dac6f900179e1e3985b76025f031144225 | |
| parent | ce13bd16dead1c53682aff8e0e3c18cfd5605f7c (diff) | |
AggregatorFactory deserialize 方法需要判断null
2 files changed, 6 insertions, 0 deletions
diff --git a/druid-hdrhistogram/src/main/java/org/apache/druid/query/aggregation/sketch/HdrHistogram/HdrHistogramAggregatorFactory.java b/druid-hdrhistogram/src/main/java/org/apache/druid/query/aggregation/sketch/HdrHistogram/HdrHistogramAggregatorFactory.java index 679125f..85cc22d 100644 --- a/druid-hdrhistogram/src/main/java/org/apache/druid/query/aggregation/sketch/HdrHistogram/HdrHistogramAggregatorFactory.java +++ b/druid-hdrhistogram/src/main/java/org/apache/druid/query/aggregation/sketch/HdrHistogram/HdrHistogramAggregatorFactory.java @@ -214,6 +214,9 @@ public class HdrHistogramAggregatorFactory extends AggregatorFactory { @Override public Object deserialize(Object object) { + if (object == null) { + return null; + } return HistogramUtils.deserializeHistogram(object); } diff --git a/druid-hlld/src/main/java/org/apache/druid/query/aggregation/sketch/hlld/HllAggregatorFactory.java b/druid-hlld/src/main/java/org/apache/druid/query/aggregation/sketch/hlld/HllAggregatorFactory.java index a5d0e0d..fa68964 100644 --- a/druid-hlld/src/main/java/org/apache/druid/query/aggregation/sketch/hlld/HllAggregatorFactory.java +++ b/druid-hlld/src/main/java/org/apache/druid/query/aggregation/sketch/hlld/HllAggregatorFactory.java @@ -165,6 +165,9 @@ public class HllAggregatorFactory extends AggregatorFactory { @Override public Object deserialize(Object object) { + if (object == null) { + return null; + } return HllUtils.deserializeHll(object); } |