drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hanifi Gunes (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (DRILL-1296) Star query fails with a nested select
Date Mon, 18 Aug 2014 23:21:18 GMT

     [ https://issues.apache.org/jira/browse/DRILL-1296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Hanifi Gunes updated DRILL-1296:
--------------------------------

    Description: 
Take two simple csv files:
{panel:title=t1.csv}
ID,Name,Lastname
9711942,name0,last0
9707867,name1,last1
{panel}

{panel:title=t2.csv}
ID,Case Number
9711942,HX362083
9707867,HX357851
{panel}

Running the following fails:
{code:sql}
select *
FROM dfs.`/path/to/t1.csv` 
where columns[0] in 
(SELECT columns[0] FROM dfs.`/path/to/t2.csv`);
{code}

{panel}
java.lang.UnsupportedOperationException: Failure finding function that runtime code generation
expected.  Signature: compare_to( INT:OPTIONALVARCHAR:OPTIONAL,  ) returns INT:REQUIRED
	at org.apache.drill.exec.expr.fn.FunctionGenerationHelper.getFunctionExpression(FunctionGenerationHelper.java:78)
	at org.apache.drill.exec.expr.fn.FunctionGenerationHelper.getComparator(FunctionGenerationHelper.java:50)
	at org.apache.drill.exec.physical.impl.common.ChainedHashTable.setupIsKeyMatchInternal(ChainedHashTable.java:214)
	at org.apache.drill.exec.physical.impl.common.ChainedHashTable.createAndSetupHashTable(ChainedHashTable.java:173)
	at org.apache.drill.exec.physical.impl.join.HashJoinBatch.setupHashTable(HashJoinBatch.java:301)
	at org.apacheError: exception while executing query: Failure while trying to get next result
batch. (state=,code=0)
.drill.exec.physical.impl.join.HashJoinBatch.executeBuildPhase(HashJoinBatch.java:328)
	at org.apache.drill.exec.physical.impl.join.HashJoinBatch.innerNext(HashJoinBatch.java:196)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
	at org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
	at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
	at org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
	at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
	at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:59)
	at org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:98)
	at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:49)
	at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:105)
	at org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:250)
{panel}


  was:
Take two simple csv files:
t1.csv:
ID,Name,Lastname
9711942,name0,last0
9707867,name1,last1
t2.csv
ID,Case Number
9711942,HX362083
9707867,HX357851

Running the following fails:
select *
FROM dfs.`/path/to/t1.csv` 
where columns[0] in 
(SELECT columns[0] FROM dfs.`/path/to/t2.csv`);

java.lang.UnsupportedOperationException: Failure finding function that runtime code generation
expected.  Signature: compare_to( INT:OPTIONALVARCHAR:OPTIONAL,  ) returns INT:REQUIRED
	at org.apache.drill.exec.expr.fn.FunctionGenerationHelper.getFunctionExpression(FunctionGenerationHelper.java:78)
	at org.apache.drill.exec.expr.fn.FunctionGenerationHelper.getComparator(FunctionGenerationHelper.java:50)
	at org.apache.drill.exec.physical.impl.common.ChainedHashTable.setupIsKeyMatchInternal(ChainedHashTable.java:214)
	at org.apache.drill.exec.physical.impl.common.ChainedHashTable.createAndSetupHashTable(ChainedHashTable.java:173)
	at org.apache.drill.exec.physical.impl.join.HashJoinBatch.setupHashTable(HashJoinBatch.java:301)
	at org.apacheError: exception while executing query: Failure while trying to get next result
batch. (state=,code=0)
.drill.exec.physical.impl.join.HashJoinBatch.executeBuildPhase(HashJoinBatch.java:328)
	at org.apache.drill.exec.physical.impl.join.HashJoinBatch.innerNext(HashJoinBatch.java:196)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
	at org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
	at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
	at org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
	at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
	at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:59)
	at org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:98)
	at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:49)
	at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:105)
	at org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:250)




> Star query fails with a nested select
> -------------------------------------
>
>                 Key: DRILL-1296
>                 URL: https://issues.apache.org/jira/browse/DRILL-1296
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Execution - Codegen, Execution - Operators
>            Reporter: Hanifi Gunes
>            Assignee: Mehant Baid
>             Fix For: 0.5.0
>
>
> Take two simple csv files:
> {panel:title=t1.csv}
> ID,Name,Lastname
> 9711942,name0,last0
> 9707867,name1,last1
> {panel}
> {panel:title=t2.csv}
> ID,Case Number
> 9711942,HX362083
> 9707867,HX357851
> {panel}
> Running the following fails:
> {code:sql}
> select *
> FROM dfs.`/path/to/t1.csv` 
> where columns[0] in 
> (SELECT columns[0] FROM dfs.`/path/to/t2.csv`);
> {code}
> {panel}
> java.lang.UnsupportedOperationException: Failure finding function that runtime code generation
expected.  Signature: compare_to( INT:OPTIONALVARCHAR:OPTIONAL,  ) returns INT:REQUIRED
> 	at org.apache.drill.exec.expr.fn.FunctionGenerationHelper.getFunctionExpression(FunctionGenerationHelper.java:78)
> 	at org.apache.drill.exec.expr.fn.FunctionGenerationHelper.getComparator(FunctionGenerationHelper.java:50)
> 	at org.apache.drill.exec.physical.impl.common.ChainedHashTable.setupIsKeyMatchInternal(ChainedHashTable.java:214)
> 	at org.apache.drill.exec.physical.impl.common.ChainedHashTable.createAndSetupHashTable(ChainedHashTable.java:173)
> 	at org.apache.drill.exec.physical.impl.join.HashJoinBatch.setupHashTable(HashJoinBatch.java:301)
> 	at org.apacheError: exception while executing query: Failure while trying to get next
result batch. (state=,code=0)
> .drill.exec.physical.impl.join.HashJoinBatch.executeBuildPhase(HashJoinBatch.java:328)
> 	at org.apache.drill.exec.physical.impl.join.HashJoinBatch.innerNext(HashJoinBatch.java:196)
> 	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
> 	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
> 	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
> 	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
> 	at org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
> 	at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
> 	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
> 	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
> 	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
> 	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
> 	at org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
> 	at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
> 	at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
> 	at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
> 	at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:59)
> 	at org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:98)
> 	at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:49)
> 	at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:105)
> 	at org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:250)
> {panel}



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

Mime
View raw message