Fix IllegalStateException at latency tracker MarkIn
@@ -54,6 +54,7 @@ public abstract class OutputRateLimiter<S extends State> implements PartitionCre
if (outputCallback != null) {
this.lockWrapper = lockWrapper;
}
+ latencyTracker = siddhiQueryContext.getLatencyTracker();
stateHolder = siddhiQueryContext.generateStateHolder(this.getClass().getName(), groupBy, init());
}
@@ -119,9 +120,5 @@ public abstract class OutputRateLimiter<S extends State> implements PartitionCre
return hasCallBack;
}
- public void setLatencyTracker(LatencyTracker latencyTracker) {
- this.latencyTracker = latencyTracker;
- }
-
}
