You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Moritz Becker <mo...@gmx.at> on 2017/05/04 10:11:45 UTC

Prepare not called on Trident window aggregators

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