Using KeyValue Multi Scheme

Hello, I have a kafka topic with keyed messages being send by a producer in it. I want to write topology where i get the key as well as the value in the storm topology, I have configured the kafka spount to use the following scheme *new KeyValueSchemeAsMultiScheme(new StringKeyValueScheme())*

connection of zookeeper

i'm new to zookeeper and using zookeeper -3.4.6 i got this when i start the connection of client 2015-11-18 08:44:53,355 [myid:] - INFO [main-SendThread(127.0.0.1:2181 ):ClientCnxn$SendThread@975] - Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate usi

Re: convert to new version problem

sorry for bad formatting now i've that supervisor still hasn't start and worker has ChannelException: Failed to bind to: 0.0.0.0/0.0.0.0:6710 i tried to execute his command ps aux | grep 6710 got this st3370 0.0 1.2 100376 13996 ?Sl 05:07 0:03 gedit /home/st/storm/apache-

Re: convert to new version problem

now i've that supervisor still hasn't start and worker has ChannelException: Failed to bind to: 0.0.0.0/0.0.0.0:6710 i tried to execute his command ps aux | grep 6710 got this st3370 0.0 1.2 100376 13996 ?Sl 05:07 0:03 gedit /home/st/storm/apache-storm-0.9.5/logs/worker-67

Re: convert to new version problem

If you have nothing else on this server that requires java, you can do: killall -9 java it should kill all java processes. You can confirm with: ps aux|fgrep java |fgrep -v grep if it returns nothing at all then you are good to go From: researcher cs Sent: Tu

答复: Storm typical application

Yes,storm can do it. I suggest you read some storm’ example.: https://github.com/apache/storm/tree/master/examples/storm-starter 发件人: Aliza Nagauker [mailto:aliza.nagau...@ecitele.com] 发送时间: 2015年11月17日 23:23 收件人: user@storm.apache.org 主题: Storm typical application Hello all, I am

Re: convert to new version problem

thanks for links , i have a bit knowledge about killing process by using the command bin/storm kill (name_of_topology) but i didn't know that when i used the old version now i deleted it and installed new version what can i do to kill any process that may be on the old !! On Tue, Nov 17, 2015 at 6

Storm typical application

Hello all, I am new at Storm. I read Storm Doc and tutorial as published in storm site and have few basic questions. I am trying to learn and understand whether Storm is suitable for my application. Is Storm mainly intended for distributed real time applications that has to handle "massive inp

Re: convert to new version problem

I think you should take a step back and read a little bit about Linux itself. http://www.howtogeek.com/107217/how-to-manage-processes-from-the-linux-terminal-10-commands-you-need-to-know/ Use te information found on this page to kill all Storm related processes and start over by following the

Re: Failed to start supervisor

Hello again, The connection is not the problem then. It is clear that Nimbus connects properly to ZooKeeper. As I mentioned earlier, the problem is with the acess control list you are providing for a given session. By the way, how come so many processes are connected to your ZooKeeper and your nim

Re: Failed to start supervisor

Hi Nick, thanks for response. 1. My ZooKeeper instance in running on localhost:5181, here is lsof -i:5181 output: COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME > java 1267 user 32u IPv6 11008 0t0 TCP *:5181 (LISTEN) > java 1267 user 33u IPv6 12398 0t0 TCP > l

Re: convert to new version problem

how can i check it and i deleted the folder of old version ? On Mon, Nov 16, 2015 at 11:11 PM, 封仲淹(纪君祥LongdaFeng) < zhongyan.f...@alibaba-inc.com> wrote: > Can you make sure every old 0.8.2 process has been killed? I guest there > are some old running process, like worker/supervisor/nimbus. > > S

Re: Failed to start supervisor

Hello Dmitry, KeeperException has to do with ZooKeeper. Why don't you check the following first: 1. Check if your ZooKeeper instance is running properly and on the machine:port you are expecting it to run. 2. Check that your Nimbus attempts to connect to the right ZooKeeper The ACL Exc

Re: Trident DRPC - Alternatives to KeyedFairBolt

Hi, Can somebody help with this? Regards, Harshal Vora www.radiolocus.com On 11/02/2015 07:54 PM, Harshal Vora wrote: Hi, We came across a few articles which mentions how KeyedFairBolt can be used to handle concurrent DRPC requests in storm. Is there any such alternative while using Trident

Failed to start supervisor

First, I started Nimbus with ${storm.home}/bin/storm nimbus It starts successfully When I'm trying to start supervisor with this command: ${storm.home}/bin/storm supervisor It prints JVM options and exit. In supervisor.log I see next message: > 2015-11-17 11:28:56.111 b.s.d.supervisor [ERROR] Erro