espertechinc / esper

Esper Complex Event Processing, Streaming SQL and Event Series Analysis
GNU General Public License v2.0
839 stars 259 forks source link

Cannot invoke "...AggregationRowRemovedCallback.removedAggregationGroupKey(Object)" because "this.removedCallback" is null #283

Closed kaicao closed 6 months ago

kaicao commented 9 months ago

Could you help us understand what can cause error of

Cannot invoke "com.espertech.esper.common.internal.epl.agg.core.AggregationRowRemovedCallback.removedAggregationGroupKey(Object)" because "this.removedCallback" is null

For filter like:

INSERT INTO some_stream
SELECT customerID as customerID,
       WINDOW(value1).distinctOf() as value1,
           value2,
           value3,
           min(startTime) AS minTimestamp,
           max(endTime) AS maxTimestamp
FROM Event(
 event.identifier IN ("Some identification")
).win:time(5 minutes) as event

GROUP BY customerID, value2, value3, event.getSomeBooleanValue()

HAVING SUM(count) > 0

OUTPUT SNAPSHOT EVERY 300 SECONDS

Esper 8.9.0 is in use.

bernhardttom commented 6 months ago

wasn't able to reproduce. Sample below

env.advanceTime(0); String epl = "select p00, min(p01), max(p01) from SupportBean_S0#time(5) as s0 " + "group by p00, s0.getP02() " + "having sum(id) > 2" + "output snapshot every 5 sec"; env.compileDeploy(epl);

long current = 5000; for (int i = 0; i < 1000; i++) { env.sendEventBean(new SupportBean_S0(1, "a", "b", "c")); env.advanceTime(5000 * i); }

env.undeployAll();