incubator-drill-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Madhu Borkar <backmeup...@gmail.com>
Subject Re: How to load data in Drill
Date Wed, 20 Nov 2013 02:36:29 GMT
Ben,
Here is log snippet using lilith..
<?xml version='1.0' encoding='UTF-8'?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "
http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html xmlns='http://www.w3.org/1999/xhtml'><head><title>Title</title><link
href='detailsView.css' rel='stylesheet'
type='text/css'/></head><body><table><tr
class='even'><th>Message</th><td><pre>Exception during
query</pre></td></tr><tr class='odd'><th>Throwable</th><td
class='throwableContainer'><div class='throwable'><a
href='ste://org.apache.drill.exec.rpc.user.QueryResultHandler.batchArrived(QueryResultHandler.java:72)'>org.apache.drill.exec.rpc.RpcException</a><pre><a
href='ste://org.apache.drill.exec.rpc.user.QueryResultHandler.batchArrived(QueryResultHandler.java:72)'>Remote
failure while running query.[error_id:
"b9ce54dd-085c-435d-b12f-e9896c60e864"
endpoint {
  address: "Node-0.etouch.net"
  user_port: 31010
  bit_port: 32011
}
error_type: 0
message: "Failure while running fragment. &lt; NullPointerException"
]</a></pre><hr/><a
href='ste://org.apache.drill.exec.rpc.user.QueryResultHandler.batchArrived(QueryResultHandler.java:72)'>at&nbsp;org.apache.drill.exec.rpc.user.QueryResultHandler.batchArrived(QueryResultHandler.java:72)&nbsp;~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]</a><a
href='ste://org.apache.drill.exec.rpc.user.UserClient.handle(UserClient.java:79)'>at&nbsp;org.apache.drill.exec.rpc.user.UserClient.handle(UserClient.java:79)&nbsp;~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]</a><a
href='ste://org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:48)'>at&nbsp;org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:48)&nbsp;~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]</a><a
href='ste://org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:33)'>at&nbsp;org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:33)&nbsp;~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]</a><a
href='ste://org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:142)'>at&nbsp;org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:142)&nbsp;~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]</a><a
href='ste://org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:127)'>at&nbsp;org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:127)&nbsp;~[java-exec-1.0.0-m1-rebuffed.jar:1.0.0-m1]</a><a
href='ste://io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)'>at&nbsp;io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)&nbsp;~[netty-codec-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)'>at&nbsp;io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)'>at&nbsp;io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)'>at&nbsp;io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)&nbsp;~[netty-codec-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)'>at&nbsp;io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)'>at&nbsp;io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:173)'>at&nbsp;io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:173)&nbsp;~[netty-codec-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)'>at&nbsp;io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:334)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)'>at&nbsp;io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:320)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785)'>at&nbsp;io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:100)'>at&nbsp;io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:100)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:497)'>at&nbsp;io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:497)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:465)'>at&nbsp;io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:465)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:359)'>at&nbsp;io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:359)&nbsp;~[netty-transport-4.0.7.Final.jar:na]</a><a
href='ste://io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101)'>at&nbsp;io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101)&nbsp;~[netty-common-4.0.7.Final.jar:na]</a><a
href='ste://java.lang.Thread.run(Thread.java:744)'>at&nbsp;java.lang.Thread.run(Thread.java:744)&nbsp;~[na:1.7.0_45]</a></div></td></tr><tr
class='even'><th>Level</th><td>ERROR</td></tr><tr
class='odd'><th>Logger</th><td>org.apache.drill.sql.client.full.ResultEnumerator</td></tr><tr
class='even'><th>Thread</th><td>main (id=1)</td></tr><tr
class='odd'><th>Timestamp</th><td>2013-11-19 18:26:42.023-0800</td></tr><tr
class='even'><th>Call&nbsp;Location</th><td><a
href='ste://org.apache.drill.sql.client.full.ResultEnumerator.moveNext(ResultEnumerator.java:43)'>at&nbsp;org.apache.drill.sql.client.full.ResultEnumerator.moveNext(ResultEnumerator.java:43)</a></td></tr><tr
class='odd'><th>Logger&nbsp;Context</th><td><table><tr><th>Name</th><td>default</td></tr><tr><th>Birthtime</th><td>2013-11-19
18:26:06.371-0800</td></tr><tr><th>Properties</th><td><table><tr><th>Key</th><th>Value</th></tr><tr><td>HOSTNAME</td><td>
Node-0.etouch.net</td></tr></table></td></tr></table></td></tr><tr
class='even'><th>Source&nbsp;ID</th><td>127.0.0.1-20131119T182606709</td></tr><tr
class='odd'><th>Local&nbsp;ID</th><td>71</td></tr></table></body></html>


On Tue, Nov 19, 2013 at 9:34 AM, Ben Becker <bbecker@maprtech.com> wrote:

> Hi Madhu,
>
> Could you report which version you're using (e.g. 1.0.0-m1.rc3), and attach
> the logs when this happens?  You can use Lilith to view the logs if you
> like (see instructions at the bottom of this
> page<
> https://cwiki.apache.org/confluence/display/DRILL/How+To+Run+Drill+with+Sample+Data#
> >
> ).
>
> Thanks,
> Ben
>
>
> On Mon, Nov 18, 2013 at 10:16 PM, Madhu Borkar <backmeupone@gmail.com
> >wrote:
>
> > I have devlopment MapR cluster. I have installed Apache Drill using
> > binaries. I could run queries with sample-data.
> >
> > I decided to load test data using pig. Here is my code
> >
> > ---------------------------------
> >
> > REGISTER file:/home/mapr/lib/parquet-pig-bundle-1.2.5.jar
> >
> > data = LOAD '$DATA'
> >
> >                 USING PigStorage(',')
> >
> > as (
> >
> >       user:    chararray,
> >
> >       street: chararray,
> >
> >       state:          chararray,
> >
> >       city:           chararray,
> >
> >       type:  chararray
> >
> >   );
> >
> >
> >
> > A = LIMIT data 3;
> >
> > dump A;
> >
> > fs -rmr /mapr-hive/parquet/data;
> >
> > STORE data INTO '/mapr-hive/parquet/data' using
> > parquet.pig.ParquetStorer();
> >
> > ----------------------
> >
> > Pig script writes to output. I moved data under apache drill directory.
> >
> >
> >
> > select * from "real-data/users.parquet";
> >
> >
> >
> > but when I try to query this data I get rpc error?
> >
> > Query failed: org.apache.drill.exec.rpc.RpcException: Remote failure
> while
> > running query.[error_id: "04ac52e4-b49e-45b8-82c5-cf480154eefd"
> >
> > endpoint {
> >
> >   address: "Node.etouch.net"
> >
> >   user_port: 31010
> >
> >   bit_port: 32011
> >
> > }
> >
> > error_type: 0
> >
> > message: "Failure while running fragment. < NullPointerException"
> >
> > ]
> >
> >
> >
> > Please, provide me help how to load data in Apache Drill.?
> >
> > Is there MapR configuration needed for Drill?
> >
> > Regards
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message