can someone have an experience on this ?
On Wed, Sep 16, 2015 at 7:00 AM, researcher cs <[email protected]>
wrote:
> Thanks for your advice and helping i found this in log file of workers
> [ERROR] Async loop died! java.lang.RuntimeException:
> org.apache.thrift7.transport.TTransportException:
> java.net.ConnectException: Connection refused at
> backtype.storm.drpc.DRPCInvocationsClient.<init>(DRPCInvocationsClient.java:23)
> at backtype.storm.drpc.DRPCSpout.open(DRPCSpout.java:69) at
> storm.trident.spout.RichSpoutBatchTriggerer.open(RichSpoutBatchTriggerer.java:41)
> at
> backtype.storm.daemon.executor$fn__3985$fn__3997.invoke(executor.clj:460)
> at backtype.storm.util$async_loop$fn__465.invoke(util.clj:375) at
> clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Unknown Source)
> Caused by: org.apache.thrift7.transport.TTransportException:
> java.net.ConnectException: Connection refused
>
> log file of supervisor
>
> supervisor [INFO] ff6460a5-aafb-44a4-a49c-2de945ffd572 still hasn't started
> 2015-09-15 02:00:54 supervisor [ERROR] Error when processing event
> org.apache.zookeeper.KeeperException$ConnectionLossException:
> KeeperErrorCode = ConnectionLoss
> at
> com.netflix.curator.ConnectionState.getZooKeeper(ConnectionState.java:72)
> at
> com.netflix.curator.CuratorZookeeperClient.getZooKeeper(CuratorZookeeperClient.java:74)
> at
> com.netflix.curator.framework.imps.CuratorFrameworkImpl.getZooKeeper(CuratorFrameworkImpl.java:353)
> at
> com.netflix.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:149)
> at
> com.netflix.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:138)
> at com.netflix.curator.RetryLoop.callWithRetry(RetryLoop.java:85)
> at
> com.netflix.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:134)
> at
> com.netflix.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:125)
> at
> com.netflix.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:34)
> at backtype.storm.zookeeper$exists_node_QMARK_.invoke(zookeeper.clj:78)
> at backtype.storm.zookeeper$mkdirs.invoke(zookeeper.clj:88)
> at
> backtype.storm.cluster$mk_distributed_cluster_state$reify__1996.set_ephemeral_node(cluster.clj:54)
> at
> backtype.storm.cluster$mk_storm_cluster_state$reify__2415.supervisor_heartbeat_BANG_(cluster.clj:300)
> at sun.reflect.GeneratedMethodAccessor13.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
> at java.lang.reflect.Method.invoke(Unknown Source)
> at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
> at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
> at
> backtype.storm.daemon.supervisor$fn__4757$exec_fn__1228__auto____4758$heartbeat_fn__4760.invoke(supervisor.clj:345)
> at backtype.storm.timer$schedule_recurring$this__1776.invoke(timer.clj:69)
> at backtype.storm.timer$mk_timer$fn__1759$fn__1760.invoke(timer.clj:33)
> at backtype.storm.timer$mk_timer$fn__1759.invoke(timer.clj:26)
> at clojure.lang.AFn.run(AFn.java:24)
> at java.lang.Thread.run(Unknown Source)
> 2015-09-15 02:00:54 supervisor [INFO] ff6460a5-aafb-44a4-a49c-2de945ffd572
> still hasn't started
> 2015-09-15 02:00:55 ClientCnxn [INFO] Client session timed out, have not
> heard from server in 20020ms for sessionid 0x14fce3996380015, closing
> socket connection and attempting reconnect
> 2015-09-15 02:00:58 ClientCnxn [INFO] Opening socket connection to server
> localhost/127.0.0.1:2181
> 2015-09-15 02:00:58 ClientCnxn [INFO] Socket connection established to
> localhost/127.0.0.1:2181, initiating session
> 2015-09-15 02:00:59 supervisor [INFO] ff6460a5-aafb-44a4-a49c-2de945ffd572
> still hasn't started
> 2015-09-15 02:01:01 supervisor [INFO] ff6460a5-aafb-44a4-a49c-2de945ffd572
> still hasn't started
> 2015-09-15 02:00:59 util [INFO] Halting process: ("Error when processing
> an event")
>
>
>
> On Tue, Sep 15, 2015 at 8:14 PM, Javier Gonzalez <[email protected]>
> wrote:
>
>> They will be in $STORM_HOME/logs on each node.
>>
>> I would suggest reading the storm documentation thoroughly so you can
>> familiarize yourself with the concepts and terminology. That way it will be
>> easier for you to ask for help and for us to help you.
>>
>> Regards,
>> Javier
>> On Sep 15, 2015 2:25 AM, "researcher cs" <[email protected]>
>> wrote:
>>
>>> Sorry for my question , i'm beginner , how can i check my supervisors
>>> and worker logs
>>>
>>> On Tue, Sep 15, 2015 at 8:11 AM, Javier Gonzalez <[email protected]>
>>> wrote:
>>>
>>>> Check your supervisor and worker logs.
>>>>
>>>> On Mon, Sep 14, 2015 at 8:14 PM, researcher cs <
>>>> [email protected]> wrote:
>>>>
>>>>> I'm new in storm and trying to submit a topology and found this
>>>>> in supervisor
>>>>>
>>>>>
>>>>>
>>>>>
>>>>> anyone can help ?
>>>>>
>>>>
>>>>
>>>>
>>>> --
>>>> Javier González Nicolini
>>>>
>>>
>>>
>
