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 < [email protected]> 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. >
