Hello, Checking if a port is used is not a Storm thing. It has to do with the processes currently running on your Server. Also, checking on the currently used ports relies on the OS you are using. I am sure if you Google how to get the used ports for your OS you will find many solutions.
Cheers, Nick On Sat, Nov 7, 2015 at 7:34 PM, researcher cs <prog.researc...@gmail.com> wrote: > sorry i'm new to storm > is this command that check !? > ps -ef|grep 67xx > > On Sat, Nov 7, 2015 at 4:17 PM, Nick R. Katsipoulakis < > nick.kat...@gmail.com> wrote: > >> Hello, >> >> It seems that port 6703 can not be binded for the worker. Are you sure >> that this port is not used by another process? >> >> Nick >> >> On Sat, Nov 7, 2015 at 7:10 PM, researcher cs <prog.researc...@gmail.com> >> wrote: >> >>> this happened when submitted topology >>> >>> On Sat, Nov 7, 2015 at 4:09 PM, researcher cs <prog.researc...@gmail.com >>> > wrote: >>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> *here what i got in worker log file [ERROR] Error on initialization of >>>> server mk-worker org.apache.storm.netty.channel.ChannelException: Failed to >>>> bind to: 0.0.0.0/0.0.0.0:6703 <http://0.0.0.0/0.0.0.0:6703> at >>>> org.apache.storm.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:272) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> backtype.storm.messaging.netty.Server.<init>(Server.java:130) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> backtype.storm.messaging.netty.Context.bind(Context.java:75) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> backtype.storm.messaging.loader$launch_receive_thread_BANG_.doInvoke(loader.clj:68) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> clojure.lang.RestFn.invoke(RestFn.java:668) [clojure-1.5.1.jar:na] at >>>> backtype.storm.daemon.worker$launch_receive_thread.invoke(worker.clj:378) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> backtype.storm.daemon.worker$fn__6959$exec_fn__1103__auto____6960.invoke(worker.clj:413) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na] at >>>> clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na] at >>>> clojure.core$apply.invoke(core.clj:617) ~[clojure-1.5.1.jar:na] at >>>> backtype.storm.daemon.worker$fn__6959$mk_worker__7015.doInvoke(worker.clj:391) >>>> [storm-core-0.9.5.jar:0.9.5] at clojure.lang.RestFn.invoke(RestFn.java:512) >>>> [clojure-1.5.1.jar:na] at >>>> backtype.storm.daemon.worker$_main.invoke(worker.clj:502) >>>> [storm-core-0.9.5.jar:0.9.5] at >>>> clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na] at >>>> clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na] at >>>> backtype.storm.daemon.worker.main(Unknown Source) >>>> [storm-core-0.9.5.jar:0.9.5] java.net.BindException: Address already in use >>>> at sun.nio.ch.Net.bind(Native Method) ~[na:1.6.0_38] at >>>> sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124) >>>> ~[na:1.6.0_38] at >>>> sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59) >>>> ~[na:1.6.0_38] at >>>> org.apache.storm.netty.channel.socket.nio.NioServerBoss$RegisterTask.run(NioServerBoss.java:193) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> org.apache.storm.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:372) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> org.apache.storm.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:296) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> org.apache.storm.netty.channel.socket.nio.NioServerBoss.run(NioServerBoss.java:42) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> org.apache.storm.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> org.apache.storm.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) >>>> ~[storm-core-0.9.5.jar:0.9.5] at >>>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) >>>> ~[na:1.6.0_38] at >>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) >>>> ~[na:1.6.0_38] at java.lang.Thread.run(Thread.java:662) ~[na:1.6.0_38]and >>>> this when executed the command that launch supervisor and worker cause of >>>> supervisor still hasn't start * >>>> >>>> >>>> >>>> *[ERROR] Halting process: ("Error on initialization") >>>> java.lang.RuntimeException: ("Error on initialization") at >>>> backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:325) >>>> [storm-core-0.9.5.jar:0.9.5] at clojure.lang.RestFn.invoke(RestFn.java:423) >>>> [clojure-1.5.1.jar:na] at >>>> backtype.storm.daemon.worker$fn__6959$mk_worker__7015.doInvoke(worker.clj:391) >>>> [storm-core-0.9.5.jar:0.9.5] at clojure.lang.RestFn.invoke(RestFn.java:512) >>>> [clojure-1.5.1.jar:na] at >>>> backtype.storm.daemon.worker$_main.invoke(worker.clj:502) >>>> [storm-core-0.9.5.jar:0.9.5] at >>>> clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na] at >>>> clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na] at >>>> backtype.storm.daemon.worker.main(Unknown Source) >>>> [storm-core-0.9.5.jar:0.9.5]* >>>> >>>> *storm version 0.9.5 * >>>> >>>> *zookeeper -3.4.6 * >>>> >>> >>> >> >> >> -- >> Nick R. Katsipoulakis, >> Department of Computer Science >> University of Pittsburgh >> > > -- Nick R. Katsipoulakis, Department of Computer Science University of Pittsburgh
