drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mehant Baid (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (DRILL-1164) Casting of a timestamp to date fails with complilation error
Date Mon, 21 Jul 2014 22:14:39 GMT

    [ https://issues.apache.org/jira/browse/DRILL-1164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14069414#comment-14069414
] 

Mehant Baid commented on DRILL-1164:
------------------------------------

Problem is in the cast function where we don't use the full package name and as a result we
get compilation error of the runtime generated code.

> Casting of a timestamp to date fails with complilation error
> ------------------------------------------------------------
>
>                 Key: DRILL-1164
>                 URL: https://issues.apache.org/jira/browse/DRILL-1164
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Functions - Drill
>            Reporter: Krystal
>            Assignee: Mehant Baid
>
> git.commit.id.abbrev=e5c2da0
> I have the following data as timestamp:
> 0: jdbc:drill:schema=dfs> select create_time from student_v where student_id=15;
> +-------------+
> | create_time |
> +-------------+
> | 2014-11-12 12:38:15.0 |
> +-------------+
> It fails with compilation error when I cast the create_time column to a date:
> 0: jdbc:drill:schema=dfs> select cast(create_time as date) from student_v where student_id=15;
> Query failed: org.apache.drill.exec.rpc.RpcException: Remote failure while running query.[error_id:
"5645a2df-cf15-4e14-aa88-c10559169348"
> endpoint {
>   address: "qa-node64.qa.lab"
>   user_port: 31010
>   control_port: 31011
>   data_port: 31012
> }
> error_type: 0
> message: "Screen received stop request sent. < SchemaChangeException:[ Failure while
attempting to load generated class ] < ClassTransformationException:[ Failure generating
transformation classes for value: 
>  
> package org.apache.drill.exec.test.generated;
> import org.apache.drill.exec.exception.SchemaChangeException;
> import org.apache.drill.exec.expr.holders.BitHolder;
> import org.apache.drill.exec.expr.holders.NullableDateHolder;
> import org.apache.drill.exec.expr.holders.NullableTimeStampHolder;
> import org.apache.drill.exec.expr.holders.NullableVarBinaryHolder;
> import org.apache.drill.exec.ops.FragmentContext;
> import org.apache.drill.exec.record.RecordBatch;
> import org.apache.drill.exec.vector.NullableDateVector;
> import org.apache.drill.exec.vector.NullableVarBinaryVector;
> public class ProjectorGen94 {
>     NullableVarBinaryVector vv0;
>     NullableDateVector vv6;
>     public void doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
>         throws SchemaChangeException
>     {
>         {
>             int[] fieldIds1 = new int[ 1 ] ;
>             fieldIds1 [ 0 ] = 1;
>             Object tmp2 = (incoming).getValueAccessorById(NullableVarBinaryVector.class,
fieldIds1).getValueVector();
>             if (tmp2 == null) {
>                 throw new SchemaChangeException("Failure while loading vector vv0 with
id: org.apache.drill.exec.record.TypedFieldId@c2277e8e.");
>             }
>             vv0 = ((NullableVarBinaryVector) tmp2);
>             /** start SETUP for function castTIMESTAMP **/ 
>             {
>                  {}
>             }
>             /** end SETUP for function castTIMESTAMP **/ 
>             /** start SETUP for function castDATE **/ 
>             {
>                  {}
>             }
>             /** end SETUP for function castDATE **/ 
>             int[] fieldIds7 = new int[ 1 ] ;
>             fieldIds7 [ 0 ] = 0;
>             Object tmp8 = (outgoing).getValueAccessorById(NullableDateVector.class, fieldIds7).getValueVector();
>             if (tmp8 == null) {
>                 throw new SchemaChangeException("Failure while loading vector vv6 with
id: org.apache.drill.exec.record.TypedFieldId@8cbf8a9.");
>             }
>             vv6 = ((NullableDateVector) tmp8);
>         }
>     }
>     public boolean doEval(int inIndex, int outIndex)
>         throws SchemaChangeException
>     {
>         {
>             NullableVarBinaryHolder out3 = new NullableVarBinaryHolder();
>             out3 .isSet = vv0 .getAccessor().isSet((inIndex));
>             if (out3 .isSet == 1) {
>                 {
>                     vv0 .getAccessor().get((inIndex), out3);
>                 }
>             }
>             //---- start of eval portion of castTIMESTAMP function. ----//
>             NullableTimeStampHolder out4 = new NullableTimeStampHolder();
>             {
>                 if (out3 .isSet == 0) {
>                     out4 .isSet = 0;
>                 } else {
>                     final NullableTimeStampHolder out = new NullableTimeStampHolder();
>                     NullableVarBinaryHolder in = out3;
>                      
> CastVarCharToTimeStamp_eval: {
>     byte[] buf = new byte[in.end - in.start];
>     in.buffer.getBytes(in.start, buf, 0, in.end - in.start);
>     String input = new String(buf, com.google.common.base.Charsets.UTF_8);
>     org.joda.time.format.DateTimeFormatter f = org.apache.drill.exec.expr.fn.impl.DateUtility.getDateTimeFormatter();
>     out.value = org.joda.time.DateTime.parse(input, f).withZoneRetainFields(org.joda.time.DateTimeZone.UTC).getMillis();
> }
>  
>                     out.isSet = 1;
>                     out4 = out;
>                     out.isSet = 1;
>                 }
>             }
>             //---- end of eval portion of castTIMESTAMP function. ----//
>             //---- start of eval portion of castDATE function. ----//
>             NullableDateHolder out5 = new NullableDateHolder();
>             {
>                 if (out4 .isSet == 0) {
>                     out5 .isSet = 0;
>                 } else {
>                     final NullableDateHolder out = new NullableDateHolder();
>                     NullableTimeStampHolder in = out4;
>                      
> CastTimeStampToDate_eval: {
>     out.value = (new DateMidnight(in.value, DateTimeZone.UTC)).getMillis();
> }
>  
>                     out.isSet = 1;
>                     out5 = out;
>                     out.isSet = 1;
>                 }
>             }
>             //---- end of eval portion of castDATE function. ----//
>             BitHolder out9 = new BitHolder();
>             out9 .value = 1;
>             if (!(out5 .isSet == 0)) {
>                 if (!vv6 .getMutator().setSafe((outIndex), out5 .value)) {
>                     out9 .value = 0;
>                 }
>             } else {
>                 if (!vv6 .getMutator().isSafe((outIndex))) {
>                     out9 .value = 0;
>                 }
>             }
>             if (out9 .value == 0) {
>                 return false;
>             }
>         }
>         {
>             return true;
>         }
>     }
> }
>  ] < CompileException:[ Line 97, Column 34: Cannot determine simple type name "DateMidnight"
]"
> ]Error: exception while executing query (state=,code=0)



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message