incubator-s4-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matthieu Morel <>
Subject Re: Adapter problem with HelloApp on multiple machines
Date Fri, 30 Nov 2012 10:34:43 GMT
Hi Emilio,

It's not clear to me why you are copying the s4r file between machines. S4 nodes actually
fetch s4r files from a location that you specify when you deploy an app. No need to copy between
hosts: nodes actually do the work of remotely fetching files.

About the error you get, it's probably related to your network configuration. You should check
with the "s4 status" tool the configuration of your s4 clusters (you'll get the host names
and ports or live nodes), and then the connectivity from the adapter host through standard
tools such as netcat or telnet.

Hope this helps,


On Nov 29, 2012, at 11:36 PM, Emilio Tapia wrote:

> Hello,
> I'm trying to test the HelloApp using 2 machines and I get an error when the adapter
tries to send a message to the second machine.
> I started the zkServer and created a "cluster1" in the first machine. Then, I created
one node in each machine. I created the .s4r file in the first machine and copied manually
to the second machine (I only copied the .s4r file). Finally, in the first machine, I created
and deployed the adapter in a second cluster using the instructions from the walkthrough and
deployed the HelloApp from the first machine; the application loads in both nodes. But I get
the following error in the adapter when it tries to send an event to the second machine (events
sent to the first machine work fine):
>         java.nio.channels.UnresolvedAddressException: null
> 	at ~[na:1.7.0_09]
> 	at ~[na:1.7.0_09]
> 	at
> 	at
> 	at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(
> 	at [netty-3.2.5.Final.jar:na]
> 	at [netty-3.2.5.Final.jar:na]
> 	at org.jboss.netty.bootstrap.ClientBootstrap.connect( [netty-3.2.5.Final.jar:na]
> 	at org.jboss.netty.bootstrap.ClientBootstrap.connect( [netty-3.2.5.Final.jar:na]
> 	at org.apache.s4.comm.tcp.TCPEmitter.connectTo( [s4-comm-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.comm.tcp.TCPEmitter.sendMessage( [s4-comm-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.comm.tcp.TCPEmitter.send( [s4-comm-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.core.RemoteSender.send( [s4-core-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.core.RemoteSenders.send( [s4-core-0.5.0-incubating.jar:0.5.0-incubating]
> 	at org.apache.s4.core.RemoteStream.put( [s4-core-0.5.0-incubating.jar:0.5.0-incubating]
> 	at hello.HelloInputAdapter$ [main/:na]
> 	at [na:1.7.0_09]
> Can anybody help me with this?
> Thanks in advance
> -- 
> Emilio Tapia

View raw message