GC overhead limit exceeded

2016-04-02 Thread sam mohel
i'm facing problem with topology i ran it in local mode and got Async loop died!java.lang.OutOfMemoryError: GC overhead limit exceeded Can you help on this ? if there is any data you need for helping just tell me Thanks in advance

Re: Aw: Re: Combining group by and time window

2016-04-02 Thread Arun Mahadevan
Hi Daniela, > Okay, could I do the grouping already in Kafka? For example would it be > possible to use one topic per region or to use one topic with a partition for > every region? Then the messages would already be grouped when the arrive at > Storm. Is this correct? You would need a kafka

Re: Storm 1.0.0 Windowing by id

2016-04-02 Thread Arun Mahadevan
Hi Filipa, Yes, you could have a separate stream per id and have a separate windowed bolt subscribe to the corresponding stream. The other option is to do the id based grouping within the windowed bolt each time its "execute" method is triggered with the tuples in the current window. Thanks,

Re: Storm 1.0.0 Windowing by id

2016-04-02 Thread Spico Florin
Hi! Depending what do you mean by and if that Id is part of the tuple. If you use for example different stream id for your clients, the answer for this post https://community.hortonworks.com/questions/24068/storm-window-support-for-streams.html gave the idea that you have different windows