incubator-s4-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matthieu Morel <mmo...@apache.org>
Subject Re: twittertopiccount app on multiple machine
Date Wed, 12 Sep 2012 08:46:03 GMT
Hi,

The steps you describe look ok, but there seems to be a connection issue
in your setup.

Are you able to connect to s4-node1 from s4-node2, in particular to the
default zookeeper port (2181)? (try: "nc -z s4-node1 2181")

What if you specify the full Zookeeper connection string "s4-node1:2181"
in the -zk parameter?


Matthieu

On 9/12/12 9:28 AM, espoir wrote:
> Hello,
> 
> I would like to work on more than one node twittertopiccount.
> I want to configure a two-node.
> Operate the twitter-counter in one node, you want to work 
> twitter-adapter on another node.
> problem occurs when you run the command on s4-node2 after you run the 
> following command in s4-node1. The nature of the error "Unable to 
> connect to zookeeper server within timeout: 10000".
> I do not know what has occurred in that the commands to run on each node 
> is incorrect.
> For running the "s4-twittertopicount" on more than one node, I want to 
> know the correct steps to perform.
> 
> Please Help
> 
> node:
> node1=s4-node1→twitter-counter
> node2=s4-node2→twitter-adapter
> 
> 
> 
> [s4-node1]
> 
> ./s4 zkServer
> 
> 
> ./s4 newCluster -c=cluster1 -nbTasks=2 -flp=12000
> 
> ./s4 newCluster -c=cluster2 -nbTasks=1 -flp=13000
> 
> 
> 
> ./s4 node -c=cluster1
> 
> 
> 
> [s4-node2]
> 
> ./s4 node -c=cluster1 -zk=s4-node1
> 
> 
> 
> 
> The following log of the problem.
> 
> -----------------------------------------------------------------------------------------------
> 
> 
> @s4-node2 incubator-s4]# ./s4 node -c=cluster1 -zk=s4-node1
> 14:41:10.178 [main] INFO  org.apache.s4.core.Main - Initializing S4 node with :
> - comm module class [org.apache.s4.comm.DefaultCommModule]
> - comm configuration file [default.s4.comm.properties from classpath]
> - core module class [org.apache.s4.core.DefaultCoreModule]
> - core configuration file[default.s4.core.properties from classpath]
> - extra modules: []
> - inline parameters: []
> 14:41:10.189 [main] DEBUG org.apache.s4.core.Main - Adding named parameters for injection
: [s4.cluster.zk_address=s4-node1]
> 14:41:10.609 [main] INFO  org.apache.s4.core.Main - Starting S4 node. This node will
automatically download applications published for the cluster it belongs to
> 14:41:21.402 [main] ERROR org.apache.s4.core.Main - Cannot start S4 node
> com.google.inject.ProvisionException: Guice provision errors:
> 
> 1) Error injecting constructor, org.I0Itec.zkclient.exception.ZkTimeoutException: Unable
to connect to zookeeper server within timeout: 10000
>    at org.apache.s4.core.Server.<init>(Server.java:71)
>    while locating org.apache.s4.core.Server
> 
> 1 error
> 	at com.google.inject.internal.InjectorImpl$4.get(InjectorImpl.java:987) ~[guice-3.0.jar:na]
> 	at com.google.inject.internal.InjectorImpl.getInstance(InjectorImpl.java:1013) ~[guice-3.0.jar:na]
> 	at org.apache.s4.core.Main.startNode(Main.java:148) [s4-core-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.core.Main.main(Main.java:75) [s4-core-0.5.0-incubating.jar:0.5.0-incubating]
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.6.0_23]
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) ~[na:1.6.0_23]
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
~[na:1.6.0_23]
> 	at java.lang.reflect.Method.invoke(Method.java:597) ~[na:1.6.0_23]
> 	at org.apache.s4.tools.Tools$Task.dispatch(Tools.java:54) [s4-tools-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.tools.Tools.main(Tools.java:94) [s4-tools-0.5.0-incubating.jar:0.5.0-incubating]
> Caused by: org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper
server within timeout: 10000
> 	at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:876) ~[zkclient-0.1.jar:na]
> 	at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98) ~[zkclient-0.1.jar:na]
> 	at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:92) ~[zkclient-0.1.jar:na]
> 	at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:80) ~[zkclient-0.1.jar:na]
> 	at org.apache.s4.core.Server.<init>(Server.java:74) ~[s4-core-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.core.Server$$FastClassByGuice$$69e0fd5b.newInstance(<generated>)
~[guice-3.0.jar:0.5.0-incubating]
> 	at com.google.inject.internal.cglib.reflect.$FastConstructor.newInstance(FastConstructor.java:40)
~[guice-3.0.jar:na]
> 	at com.google.inject.internal.DefaultConstructionProxyFactory$1.newInstance(DefaultConstructionProxyFactory.java:60)
~[guice-3.0.jar:na]
> 	at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85)
~[guice-3.0.jar:na]
> 	at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:254)
~[guice-3.0.jar:na]
> 	at com.google.inject.internal.InjectorImpl$4$1.call(InjectorImpl.java:978) ~[guice-3.0.jar:na]
> 	at com.google.inject.internal.InjectorImpl.callInContext(InjectorImpl.java:1024) ~[guice-3.0.jar:na]
> 	at com.google.inject.internal.InjectorImpl$4.get(InjectorImpl.java:974) ~[guice-3.0.jar:na]
> 	... 9 common frames omitted
> 
> 
> 
> 
> Thanks,
> 
> espoir
> 
> 


Mime
View raw message