You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@drill.apache.org by Pratik Khedkar <pr...@games24x7.com> on 2016/12/07 06:52:32 UTC
[1.9.0] : Error: SYSTEM ERROR: MalformedInputException: Input length
= 1
Hi Team,
I am getting below error after upgrading drill from 1.6 to 1.9.
Working fine in 1.6. Kindly help me in this.
*Query* :-
create table a_tt1_new as select sessionid,userid,dchannelid as
channelid,id,event,hreferer as url_ref,case when (strpos(url,'?')-1) <>
'-1' then LandingPage(substr(url, 1, strpos(url,'?')-1)) else url end as
url ,timestamp_url,timestamp_url_client,update_date
from gllva_dump where ((lp not like 'NA' and dchannelid <> 3) OR event like
'notification%' OR (event = 'e.a' and url like 'https://abc/bring-f/xy.html%'
and ((Base64Conv(ar) like '%message%success%' and
Base64Conv(ar) like '%bonusearned%' ) or (Base64Conv(ar) like
'%inviteSent%true%' and Base64Conv(ar) like
'%tyou.html%'))) or (id = 'btn_d' and event = 'g.c') OR (id like 'plner%'
or id like 'mob-banner%' or id like 'player%' or id like '%banner%') OR
(url like '%pro/pro.html%' or url like '%pro/pro.html%') OR ((event =
'e.m' and id = 'rdCTA') OR (id = 'rdClicked' and event = 'rdClicked') OR
(event = 'g.c' and id like 'rewar_tophead%')) OR ((event ='g.c' and (id =
'reg_m' OR id = 'reg_f')) OR (id = '/reg/regff.html')));
*Stack Trace* :-
Error: SYSTEM ERROR: MalformedInputException: Input length = 1
Fragment 1:3
[Error Id: ebc15806-831b-47ab-8b73-e79206b065a2 on datanode2:31010]
(state=,code=0)
java.sql.SQLException: SYSTEM ERROR: MalformedInputException: Input length
= 1
Fragment 1:3
[Error Id: ebc15806-831b-47ab-8b73-e79206b065a2 on datanode2:31010]
at
org.apache.drill.jdbc.impl.DrillCursor.nextRowInternally(DrillCursor.java:232)
at
org.apache.drill.jdbc.impl.DrillCursor.loadInitialSchema(DrillCursor.java:275)
at
org.apache.drill.jdbc.impl.DrillResultSetImpl.execute(DrillResultSetImpl.java:1943)
at
org.apache.drill.jdbc.impl.DrillResultSetImpl.execute(DrillResultSetImpl.java:76)
at
org.apache.calcite.avatica.AvaticaConnection$1.execute(AvaticaConnection.java:473)
at
org.apache.drill.jdbc.impl.DrillMetaImpl.prepareAndExecute(DrillMetaImpl.java:465)
at
org.apache.calcite.avatica.AvaticaConnection.prepareAndExecuteInternal(AvaticaConnection.java:477)
at
org.apache.drill.jdbc.impl.DrillConnectionImpl.prepareAndExecuteInternal(DrillConnectionImpl.java:169)
at
org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement.java:109)
at
org.apache.calcite.avatica.AvaticaStatement.execute(AvaticaStatement.java:121)
at
org.apache.drill.jdbc.impl.DrillStatementImpl.execute(DrillStatementImpl.java:101)
at sqlline.Commands.execute(Commands.java:841)
at sqlline.Commands.sql(Commands.java:751)
at sqlline.SqlLine.dispatch(SqlLine.java:746)
at sqlline.SqlLine.runCommands(SqlLine.java:1651)
at sqlline.Commands.run(Commands.java:1304)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
sqlline.ReflectiveCommandHandler.execute(ReflectiveCommandHandler.java:36)
at sqlline.SqlLine.dispatch(SqlLine.java:742)
at sqlline.SqlLine.initArgs(SqlLine.java:553)
at sqlline.SqlLine.begin(SqlLine.java:596)
at sqlline.SqlLine.start(SqlLine.java:375)
at sqlline.SqlLine.main(SqlLine.java:268)
Caused by: org.apache.drill.common.exceptions.UserRemoteException: SYSTEM
ERROR: MalformedInputException: Input length = 1
Fragment 1:3
[Error Id: ebc15806-831b-47ab-8b73-e79206b065a2 on datanode2:31010]
at
org.apache.drill.exec.rpc.user.QueryResultHandler.resultArrived(QueryResultHandler.java:123)
at
org.apache.drill.exec.rpc.user.UserClient.handleReponse(UserClient.java:144)
at
org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:46)
at
org.apache.drill.exec.rpc.BasicClientWithConnection.handle(BasicClientWithConnection.java:31)
at org.apache.drill.exec.rpc.RpcBus.handle(RpcBus.java:65)
at
org.apache.drill.exec.rpc.RpcBus$RequestEvent.run(RpcBus.java:363)
at
org.apache.drill.common.SerializedExecutor$RunnableProcessor.run(SerializedExecutor.java:89)
at
org.apache.drill.exec.rpc.RpcBus$SameExecutor.execute(RpcBus.java:240)
at
org.apache.drill.common.SerializedExecutor.execute(SerializedExecutor.java:123)
at
org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:274)
at
org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:245)
at
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
at
io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
at
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
at
io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
at java.lang.Thread.run(Thread.java:745)
Regards,
Pratik K.
Re: [1.9.0] : Error: SYSTEM ERROR: MalformedInputException: Input
length = 1
Posted by Khurram Faraaz <kf...@maprtech.com>.
Is your data the same on 1.6.0 and 1.9.0, or did your data change by any
chance when/after upgrading from 1.6.0 to 1.9.0 ?
On Wed, Dec 7, 2016 at 12:22 PM, Pratik Khedkar <
pratik.khedkar@games24x7.com> wrote:
> Hi Team,
>
> I am getting below error after upgrading drill from 1.6 to 1.9.
> Working fine in 1.6. Kindly help me in this.
>
> *Query* :-
> create table a_tt1_new as select sessionid,userid,dchannelid as
> channelid,id,event,hreferer as url_ref,case when (strpos(url,'?')-1) <>
> '-1' then LandingPage(substr(url, 1, strpos(url,'?')-1)) else url end as
> url ,timestamp_url,timestamp_url_client,update_date
> from gllva_dump where ((lp not like 'NA' and dchannelid <> 3) OR event like
> 'notification%' OR (event = 'e.a' and url like '
> https://abc/bring-f/xy.html%'
> and ((Base64Conv(ar) like '%message%success%' and
> Base64Conv(ar) like '%bonusearned%' ) or (Base64Conv(ar) like
> '%inviteSent%true%' and Base64Conv(ar) like
> '%tyou.html%'))) or (id = 'btn_d' and event = 'g.c') OR (id like 'plner%'
> or id like 'mob-banner%' or id like 'player%' or id like '%banner%') OR
> (url like '%pro/pro.html%' or url like '%pro/pro.html%') OR ((event =
> 'e.m' and id = 'rdCTA') OR (id = 'rdClicked' and event = 'rdClicked') OR
> (event = 'g.c' and id like 'rewar_tophead%')) OR ((event ='g.c' and (id =
> 'reg_m' OR id = 'reg_f')) OR (id = '/reg/regff.html')));
>
> *Stack Trace* :-
>
> Error: SYSTEM ERROR: MalformedInputException: Input length = 1
>
> Fragment 1:3
>
> [Error Id: ebc15806-831b-47ab-8b73-e79206b065a2 on datanode2:31010]
> (state=,code=0)
> java.sql.SQLException: SYSTEM ERROR: MalformedInputException: Input length
> = 1
>
> Fragment 1:3
>
> [Error Id: ebc15806-831b-47ab-8b73-e79206b065a2 on datanode2:31010]
> at
> org.apache.drill.jdbc.impl.DrillCursor.nextRowInternally(
> DrillCursor.java:232)
> at
> org.apache.drill.jdbc.impl.DrillCursor.loadInitialSchema(
> DrillCursor.java:275)
> at
> org.apache.drill.jdbc.impl.DrillResultSetImpl.execute(
> DrillResultSetImpl.java:1943)
> at
> org.apache.drill.jdbc.impl.DrillResultSetImpl.execute(
> DrillResultSetImpl.java:76)
> at
> org.apache.calcite.avatica.AvaticaConnection$1.execute(
> AvaticaConnection.java:473)
> at
> org.apache.drill.jdbc.impl.DrillMetaImpl.prepareAndExecute(
> DrillMetaImpl.java:465)
> at
> org.apache.calcite.avatica.AvaticaConnection.prepareAndExecuteInternal(
> AvaticaConnection.java:477)
> at
> org.apache.drill.jdbc.impl.DrillConnectionImpl.prepareAndExecuteInternal(
> DrillConnectionImpl.java:169)
> at
> org.apache.calcite.avatica.AvaticaStatement.executeInternal(
> AvaticaStatement.java:109)
> at
> org.apache.calcite.avatica.AvaticaStatement.execute(
> AvaticaStatement.java:121)
> at
> org.apache.drill.jdbc.impl.DrillStatementImpl.execute(
> DrillStatementImpl.java:101)
> at sqlline.Commands.execute(Commands.java:841)
> at sqlline.Commands.sql(Commands.java:751)
> at sqlline.SqlLine.dispatch(SqlLine.java:746)
> at sqlline.SqlLine.runCommands(SqlLine.java:1651)
> at sqlline.Commands.run(Commands.java:1304)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:
> 62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(
> DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> sqlline.ReflectiveCommandHandler.execute(ReflectiveCommandHandler.java:36)
> at sqlline.SqlLine.dispatch(SqlLine.java:742)
> at sqlline.SqlLine.initArgs(SqlLine.java:553)
> at sqlline.SqlLine.begin(SqlLine.java:596)
> at sqlline.SqlLine.start(SqlLine.java:375)
> at sqlline.SqlLine.main(SqlLine.java:268)
> Caused by: org.apache.drill.common.exceptions.UserRemoteException: SYSTEM
> ERROR: MalformedInputException: Input length = 1
>
> Fragment 1:3
>
> [Error Id: ebc15806-831b-47ab-8b73-e79206b065a2 on datanode2:31010]
> at
> org.apache.drill.exec.rpc.user.QueryResultHandler.resultArrived(
> QueryResultHandler.java:123)
> at
> org.apache.drill.exec.rpc.user.UserClient.handleReponse(
> UserClient.java:144)
> at
> org.apache.drill.exec.rpc.BasicClientWithConnection.handle(
> BasicClientWithConnection.java:46)
> at
> org.apache.drill.exec.rpc.BasicClientWithConnection.handle(
> BasicClientWithConnection.java:31)
> at org.apache.drill.exec.rpc.RpcBus.handle(RpcBus.java:65)
> at
> org.apache.drill.exec.rpc.RpcBus$RequestEvent.run(RpcBus.java:363)
> at
> org.apache.drill.common.SerializedExecutor$RunnableProcessor.run(
> SerializedExecutor.java:89)
> at
> org.apache.drill.exec.rpc.RpcBus$SameExecutor.execute(RpcBus.java:240)
> at
> org.apache.drill.common.SerializedExecutor.execute(
> SerializedExecutor.java:123)
> at
> org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:274)
> at
> org.apache.drill.exec.rpc.RpcBus$InboundHandler.decode(RpcBus.java:245)
> at
> io.netty.handler.codec.MessageToMessageDecoder.channelRead(
> MessageToMessageDecoder.java:89)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
> AbstractChannelHandlerContext.java:339)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:324)
> at
> io.netty.handler.timeout.IdleStateHandler.channelRead(
> IdleStateHandler.java:254)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
> AbstractChannelHandlerContext.java:339)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:324)
> at
> io.netty.handler.codec.MessageToMessageDecoder.channelRead(
> MessageToMessageDecoder.java:103)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
> AbstractChannelHandlerContext.java:339)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:324)
> at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(
> ByteToMessageDecoder.java:242)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
> AbstractChannelHandlerContext.java:339)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:324)
> at
> io.netty.channel.ChannelInboundHandlerAdapter.channelRead(
> ChannelInboundHandlerAdapter.java:86)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
> AbstractChannelHandlerContext.java:339)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:324)
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(
> DefaultChannelPipeline.java:847)
> at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(
> AbstractNioByteChannel.java:131)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(
> NioEventLoop.java:511)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(
> NioEventLoop.java:468)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(
> NioEventLoop.java:382)
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$2.
> run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
>
>
> Regards,
> Pratik K.
>