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
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
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,
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