Hello!
I would like to know that besides the companies mentioned on the
documentation
(http://storm.apache.org/documentation/Powered-By.html), if they are any
companies that have deployed Storm on production and what were their case
study (the way that is also described in the documentation).
Hi,
I'm relatively new to Storm, a couple of months using it. So, excuse any
stupid question I might post :-)
I have a somewhat complex topology... At some point while developing it I
have made some change that is producing following exception
-
Hi.
This seem to be related to the fact that there are other threads (some
custom threads) interacting with my custom bolts. Removing them fixes the
problem.
Side note: my bolts accumulate data and at some point when new data arrive
they dump this accumulated data... if no new data arrives at
Michel,
On Fri, Dec 12, 2014 at 5:10 PM, Michael Rose mich...@fullcontact.com
wrote:
Hi Ernesto,
Have multi-threaded bolts is fine as long as you synchronize on the
OutputCollector before emitting/acking. That'll solve your issue.
Thanks for your answer! Even if the thread is not a Storm
That's correct. Normally you use OutputCollector in a single thread (the
executor thread for the bolt). If your bolt is multithreaded, just
synchronize the entire collector no matter what thread you're
emitting/acking/failing from.
Michael Rose (@Xorlev https://twitter.com/xorlev)
Senior Platform
I’m currently looking at ways to leverage the Storm HTTP APIs to monitor the
health of our storm cluster and a running topology in particular. I can get all
the statistics I need when I know a particular topology ID, parsing the json
returned from a URL like:
Here I found if I use a RandomTupleSpout which implements IBatchSpout to
replace OpaqueTridentKafkaSpout,
static class RandomTupleSpout implements IBatchSpout {
private transient Random random;
private static final int BATCH = 1000;
@Override
