Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Drill >> mail # user >> Distributed mode troubles: ZK/Curator connection time out


+
Michael Hausenblas 2013-10-27, 21:00
+
Steven Phillips 2013-10-27, 21:32
+
Michael Hausenblas 2013-10-27, 21:57
+
Steven Phillips 2013-10-27, 22:17
+
Michael Hausenblas 2013-10-27, 22:39
+
Steven Phillips 2013-10-27, 22:44
+
Steven Phillips 2013-10-27, 22:48
Copy link to this message
-
Re: Distributed mode troubles: ZK/Curator connection time out

Interestingly enough now it works. Can it be that due to whatever reasons there must be an Internet connection available?. BTW, I’m doing the stuff on MacOS 10.9.

$ bin/submit_plan -f sample-data/physical_json_scan_test1.json -t physical -zk 127.0.0.1:2181

--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| id             | type           | name           | ppu            | sales          | batters.batter.id| batters.batter.type| topping.id     | topping.type   | filling.id     | filling.type   |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| 0001           | donut          | Cake           | 0.55           | 35
Still, strangely enough there are errors in submitter.log (that do not affect the result, but would love to understand what’s going on here):

[[

09:37:20.632 [Client-1] DEBUG o.a.d.e.rpc.user.QueryResultHandler - Received QueryId part1: 3952191315122866480
part2: -6119095990164217550
 succesfully.  Adding listener org.apache.drill.exec.client.QuerySubmitter$QueryResultsListener@1d007a1a
09:37:27.005 [Client-1] ERROR o.a.d.exec.rpc.RpcExceptionHandler - Exception in pipeline.  Closing channel between local /10.109.7.56:63536 and remote /10.109.7.56:31012
io.netty.handler.codec.DecoderException: java.lang.IndexOutOfBoundsException
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:99) [netty-codec-4.0.7.Final.jar:na]
at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320) [netty-transport-4.0.7.Final.jar:na]
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) [netty-codec-4.0.7.Final.jar:na]
at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320) [netty-transport-4.0.7.Final.jar:na]
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:173) [netty-codec-4.0.7.Final.jar:na]
at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:100) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:497) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:465) [netty-transport-4.0.7.Final.jar:na]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:359) [netty-transport-4.0.7.Final.jar:na]
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) [netty-common-4.0.7.Final.jar:na]
at java.lang.Thread.run(Thread.java:722) [na:1.7.0_11]
Caused by: java.lang.IndexOutOfBoundsException: null
at io.netty.buffer.EmptyByteBuf.checkIndex(EmptyByteBuf.java:857) ~[netty-buffer-4.0.7.Final.jar:na]
at io.netty.buffer.EmptyByteBuf.getBytes(EmptyByteBuf.java:321) ~[netty-buffer-4.0.7.Final.jar:na]
at org.apache.drill.exec.vector.VarCharVector$Accessor.get(VarCharVector.java:240) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.vector.VarCharVector$Accessor.getObject(VarCharVector.java:257) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.vector.NullableVarCharVector$Accessor.getObject(NullableVarCharVector.java:244) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.client.QuerySubmitter$QueryResultsListener.resultArrived(QuerySubmitter.java:103) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.rpc.user.QueryResultHandler.batchArrived(QueryResultHandler.java:75) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.rpc.user.UserClient.handle(UserClient.java:79) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:48) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:33) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:142) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:127) ~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89) [netty-codec-4.0.7.Final.jar:na]
... 15 common frames omitted

]]
Cheers,
Michael

Michael Hausenblas
Ireland, Europe
http://mhausenblas.info/

On 27 Oct 2013, at 22:48, Steven Phillips <[EMAIL PROTECTED]> wrote:

+
Jacques Nadeau 2013-10-28, 20:15
+
Michael Hausenblas 2013-10-28, 09:26
+
Steven Phillips 2013-10-27, 22:35
+
Michael Hausenblas 2013-10-27, 22:42
+
Timothy Chen 2013-10-27, 21:50
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB