You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Josh J <jo...@gmail.com> on 2014/07/30 18:29:49 UTC

docker storm ambassador pattern - multiple machiens

Hi,

I was wondering if anyone had tried to run docker and storm on multiple
machines?  There is the ambassador pattern
<https://docs.docker.com/articles/ambassador_pattern_linking/> that is
suggested, though I'm having strange serialization errors. Has anyone else
tried this approach?

Thanks,
Josh

Re: docker storm ambassador pattern - multiple machiens

Posted by Josh J <jo...@gmail.com>.
I'm receiving the following error in storm UI

org.apache.thrift7.transport.TTransportException:
java.net.SocketException: Broken pipe
	at org.apache.thrift7.transport.TIOStreamTransport.write(TIOStreamTransport.java:147)
	at org.apache.thrift7.transport.TFramedTransport.flush(TFramedTransport.java:157)
	at org.apache.thrift7.TServiceClient.sendBase(TServiceClient.java:65)
	at backtype.storm.generated.Nimbus$Client.send_getClusterInfo(Nimbus.java:462)
	at backtype.storm.generated.Nimbus$Client.getClusterInfo(Nimbus.java:455)
	at backtype.storm.ui.core$supervisor_summary.invoke(core.clj:481)
	at backtype.storm.ui.core$fn__8225.invoke(core.clj:791)
	at compojure.core$make_route$fn__3365.invoke(core.clj:93)
	at compojure.core$if_route$fn__3353.invoke(core.clj:39)
	at compojure.core$if_method$fn__3346.invoke(core.clj:24)
	at compojure.core$routing$fn__3371.invoke(core.clj:106)
	at clojure.core$some.invoke(core.clj:2443)
	at compojure.core$routing.doInvoke(core.clj:106)
	at clojure.lang.RestFn.applyTo(RestFn.java:139)
	at clojure.core$apply.invoke(core.clj:619)
	at compojure.core$routes$fn__3375.invoke(core.clj:111)
	at ring.middleware.reload$wrap_reload$fn__7540.invoke(reload.clj:14)
	at backtype.storm.ui.core$catch_errors$fn__8268.invoke(core.clj:858)
	at ring.middleware.keyword_params$wrap_keyword_params$fn__4029.invoke(keyword_params.clj:27)
	at ring.middleware.nested_params$wrap_nested_params$fn__4068.invoke(nested_params.clj:65)
	at ring.middleware.params$wrap_params$fn__4001.invoke(params.clj:55)
	at ring.middleware.multipart_params$wrap_multipart_params$fn__4096.invoke(multipart_params.clj:103)
	at ring.middleware.flash$wrap_flash$fn__4277.invoke(flash.clj:14)
	at ring.middleware.session$wrap_session$fn__4266.invoke(session.clj:43)
	at ring.middleware.cookies$wrap_cookies$fn__4197.invoke(cookies.clj:160)
	at ring.adapter.jetty$proxy_handler$fn__7179.invoke(jetty.clj:16)
	at ring.adapter.jetty.proxy$org.mortbay.jetty.handler.AbstractHandler$0.handle(Unknown
Source)
	at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
	at org.mortbay.jetty.Server.handle(Server.java:326)
	at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)
	at org.mortbay.jetty.HttpConnection$RequestHandler.headerComplete(HttpConnection.java:928)
	at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:549)
	at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:212)
	at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)
	at org.mortbay.jetty.bio.SocketConnector$Connection.run(SocketConnector.java:228)
	at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582)
Caused by: java.net.SocketException: Broken pipe
	at java.net.SocketOutputStream.socketWrite0(Native Method)
	at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:113)
	at java.net.SocketOutputStream.write(SocketOutputStream.java:159)
	at org.apache.thrift7.transport.TIOStreamTransport.write(TIOStreamTransport.java:145)
	... 35 more




On Wed, Jul 30, 2014 at 6:29 PM, Josh J <jo...@gmail.com> wrote:

> Hi,
>
> I was wondering if anyone had tried to run docker and storm on multiple
> machines?  There is the ambassador pattern
> <https://docs.docker.com/articles/ambassador_pattern_linking/> that is
> suggested, though I'm having strange serialization errors. Has anyone else
> tried this approach?
>
> Thanks,
> Josh
>