From 14d06ca0bc382789dbf460f5102aaa33b5e833fd Mon Sep 17 00:00:00 2001 From: lifengchao Date: Mon, 16 Oct 2023 17:42:48 +0800 Subject: [PATCH] =?UTF-8?q?AggregatorFactory=20deserialize=20=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E9=9C=80=E8=A6=81=E5=88=A4=E6=96=ADnull?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sketch/HdrHistogram/HdrHistogramAggregatorFactory.java | 3 +++ .../query/aggregation/sketch/hlld/HllAggregatorFactory.java | 3 +++ 2 files changed, 6 insertions(+) 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); }