Neelesh,
Can you post full worker log on this?
Sean
On Tue, Jun 10, 2014 at 5:44 AM, Neelesh neele...@gmail.com wrote:
Client is being closed, and does not take requests any more
If you are talking about starting nimbus/supervisor distributely on the
cluster, you should try storm-yarn, there is API to do so.
If you are talking about starting nimbus/supervisor on a host jvm process,
after compilation, there will be
class backtype.storm.scheduler.ISupervisor.supervisor,
#3 - 3 points
#10 - 2 points
On Mon, May 19, 2014 at 2:55 AM, Cody A. Ray cody.a@gmail.com wrote:
#1 - 2 points
#4 - 1 point
#10 - 2 points
On Sun, May 18, 2014 at 1:19 PM, Nathan Marz nat...@nathanmarz.comwrote:
#10 - 5 points
On Sun, May 18, 2014 at 4:47 AM, Marco
Can share you topology configuration？
And what is the heap usage looks like?
Sean
On Fri, May 9, 2014 at 1:44 PM, Lasantha Fernando lasantha@gmail.comwrote:
So wondering if it is the same issue or maybe there is some configuration
I've done incorrectly?
Any idea why this is happening?
Basically it means your spout is too slow.
You need to rewrite it like the suggestions above, and also adjust
topology.max.spout.pending to a bigger number.
On Thu, Mar 20, 2014 at 6:45 PM, David Crossland da...@elastacloud.comwrote:
my spout, thanks for that.. looks like I've got a 1267.486
What is the type of _collector?
If it is SpoutOutputCollector, you can change from:
if(message instanceof MonetiseEvent)
{
logger.log(Level.DEBUG, recieved monetise message);
_collector.emit(new Values(message));
_collector.ack(tuple);
}
Seems to be a python import error
On Wed, Mar 19, 2014 at 1:32 PM, yogesh panchal yspanc...@gmail.com wrote:
ImportError
https://github.com/wurstmeister/storm-kafka-0.8-plus
On Mon, Mar 17, 2014 at 2:04 PM, Manthosh Kumar T manth...@gmail.comwrote:
Hi All,
Is Kafka Spout still in use?. I mean given that it doesn't
support the latest version of Kafka (0.8), is it still under development?.
Will
checked that already. Is that used widely?.
On 17 March 2014 11:36, Sean Zhong clock...@gmail.com wrote:
https://github.com/wurstmeister/storm-kafka-0.8-plus
On Mon, Mar 17, 2014 at 2:04 PM, Manthosh Kumar T manth...@gmail.comwrote:
Hi All,
Is Kafka Spout still in use?. I mean
IMHO, storm-yarn and storm-starter, should be brought in first.
storm-start is simple, easy to maintain, and servers a good startpoint.
storm-yarn is necessary to work with HADOOP2.
With these, the user can immediately have a workable storm cluster on YARN,
so it is more basic.
Storm connectors
10 matches
Mail list logo
