drill-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yash Sharma <yash...@gmail.com>
Subject Re: Issue in running LogicalPlan generated by drill
Date Tue, 14 Oct 2014 18:58:44 GMT
Finally cracked it. Just a misplaced @JsonProperty annotation.
https://github.com/apache/incubator-drill/blob/9e164662f5296f7048c880c40bc551030fb58cca/common/src/main/java/org/apache/drill/common/logical/data/Join.java#L59

Attached a patch for the same:
https://issues.apache.org/jira/browse/DRILL-1535

Thanks

On Mon, Oct 13, 2014 at 10:55 PM, Yash Sharma <yash360@gmail.com> wrote:

> Thanks Jacques. I have seen this prob typically with a Join query plan.
> Will try to dig in more.
> On 13/10/2014 10:21 pm, "Jacques Nadeau" <jacques@apache.org> wrote:
>
>> Technically, Drill doesn't serialize into JSON and then deserialize again
>> before running a SQL query. As such, on occasion, we've had problems with
>> serialized plans running as we have failed to maintain JSON compatibility.
>> There is probably some issue with Jackson annotations on the objects that
>> are failing to deserialize.
>>
>> On Sun, Oct 12, 2014 at 11:44 PM, Yash Sharma <yash360@gmail.com> wrote:
>>
>> > Hi Folks,
>> > I am trying to run a LogicalPlan (generated by Drill) on the Web
>> Interface.
>> > I face this below error. Same query works directly on Sqlline.
>> >
>> > Any Tips what might be wrong ?
>> >
>> > Thanks
>> >
>> > Error on executing logical plan on web console:
>> > Query failed: Failure while parsing logical plan. Argument #0 of
>> > constructor [constructor for org.apache.drill.common.logical.data.Join,
>> > annotations: [null]] has no property name annotation; must have name
>> when
>> > multiple-paramater constructor annotated as Creator
>> > [64eb4dc2-dd1d-456a-a820-2b1c68050b5e]
>> >
>> >
>> > Query:
>> > explain plan without implementation for(select c.c_custkey, c.c_name,
>> > c.c_address, c.c_nationkey,  n.n_name, n.n_comment from
>> > cp.`tpch/customer.parquet` c FULL OUTER JOIN cp.`tpch/nation.parquet` n
>> ON
>> > (c.c_nationkey = n.n_nationkey) limit 10) ;
>> >
>> >
>> > Logical Plan Generated:
>> > {
>> >   "head" : {
>> >     "version" : 1,
>> >     "generator" : {
>> >       "type" : "org.apache.drill.exec.planner.logical.DrillImplementor",
>> >       "info" : ""
>> >     },
>> >     "type" : "APACHE_DRILL_LOGICAL",
>> >     "options" : null,
>> >     "queue" : 0,
>> >     "resultMode" : "LOGICAL"
>> >   },
>> >   "storage" : {
>> >     "cp" : {
>> >       "type" : "file",
>> >       "enabled" : true,
>> >       "connection" : "classpath:///",
>> >       "workspaces" : null,
>> >       "formats" : {
>> >         "csv" : {
>> >           "type" : "text",
>> >           "extensions" : [ "csv" ],
>> >           "delimiter" : ","
>> >         },
>> >         "json" : {
>> >           "type" : "json"
>> >         },
>> >         "parquet" : {
>> >           "type" : "parquet"
>> >         }
>> >       }
>> >     }
>> >   },
>> >   "query" : [ {
>> >     "op" : "scan",
>> >     "@id" : 1,
>> >     "storageengine" : "cp",
>> >     "selection" : {
>> >       "format" : {
>> >         "type" : "named",
>> >         "name" : "parquet"
>> >       },
>> >       "files" : [ "/tpch/customer.parquet" ]
>> >     }
>> >   }, {
>> >     "op" : "project",
>> >     "@id" : 2,
>> >     "input" : 1,
>> >     "projections" : [ {
>> >       "ref" : "`c_nationkey`",
>> >       "expr" : "`c_nationkey`"
>> >     }, {
>> >       "ref" : "`c_custkey`",
>> >       "expr" : "`c_custkey`"
>> >     }, {
>> >       "ref" : "`c_name`",
>> >       "expr" : "`c_name`"
>> >     }, {
>> >       "ref" : "`c_address`",
>> >       "expr" : "`c_address`"
>> >     } ]
>> >   }, {
>> >     "op" : "scan",
>> >     "@id" : 3,
>> >     "storageengine" : "cp",
>> >     "selection" : {
>> >       "format" : {
>> >         "type" : "named",
>> >         "name" : "parquet"
>> >       },
>> >       "files" : [ "/tpch/nation.parquet" ]
>> >     }
>> >   }, {
>> >     "op" : "project",
>> >     "@id" : 4,
>> >     "input" : 3,
>> >     "projections" : [ {
>> >       "ref" : "`n_nationkey`",
>> >       "expr" : "`n_nationkey`"
>> >     }, {
>> >       "ref" : "`n_name`",
>> >       "expr" : "`n_name`"
>> >     }, {
>> >       "ref" : "`n_comment`",
>> >       "expr" : "`n_comment`"
>> >     } ]
>> >   }, {
>> >     "op" : "join",
>> >     "@id" : 5,
>> >     "right" : 4,
>> >     "left" : 2,
>> >     "conditions" : [ {
>> >       "relationship" : "==",
>> >       "left" : "`c_nationkey`",
>> >       "right" : "`n_nationkey`"
>> >     } ],
>> >     "type" : "FULL"
>> >   }, {
>> >     "op" : "project",
>> >     "@id" : 6,
>> >     "input" : 5,
>> >     "projections" : [ {
>> >       "ref" : "`c_custkey`",
>> >       "expr" : "`c_custkey`"
>> >     }, {
>> >       "ref" : "`c_name`",
>> >       "expr" : "`c_name`"
>> >     }, {
>> >       "ref" : "`c_address`",
>> >       "expr" : "`c_address`"
>> >     }, {
>> >       "ref" : "`c_nationkey`",
>> >       "expr" : "`c_nationkey`"
>> >     }, {
>> >       "ref" : "`n_name`",
>> >       "expr" : "`n_name`"
>> >     }, {
>> >       "ref" : "`n_comment`",
>> >       "expr" : "`n_comment`"
>> >     } ]
>> >   }, {
>> >     "op" : "limit",
>> >     "@id" : 7,
>> >     "input" : 6,
>> >     "first" : 0,
>> >     "last" : 10
>> >   }, {
>> >     "op" : "store",
>> >     "@id" : 8,
>> >     "input" : 7,
>> >     "target" : null,
>> >     "storageEngine" : "--SCREEN--"
>> >   } ]
>> > }
>> >
>>
>

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