Hi,

I noticed that when using
org.apache.storm.trident.Stream#slidingWindow(...), the
org.apache.storm.trident.operation.Operation#prepare method is not
invoked on the passed aggregator. This causes the
org.apache.storm.trident.operation.impl.GroupedAggregator to be unusable
in a sliding window scenario.

Shouldn't 'prepare' be invoked for the aggregator in
org.apache.storm.trident.windowing.WindowTridentProcessor#prepare?

I am using Storm 1.1.0

Thank you

Reply via email to