[
https://issues.apache.org/jira/browse/VXQUERY-88?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13642531#comment-13642531
]
Preston Carman commented on VXQUERY-88:
---------------------------------------
The following assign is turned into the below subplan.
assign [$$7] <- [function-call:
vxquery:{urn:org.apache.vxquery.operators-ext}sort-distinct-nodes-asc-or-atomics,
Args:[%0->$$6]] -- |UNPARTITIONED|
subplan {
aggregate [$$7] <- [function-call:
vxquery:{urn:org.apache.vxquery.operators-ext}sequence, Args:[%0->$$10]] --
|UNPARTITIONED|
order (ASC, %0->$$11) -- |UNPARTITIONED|
group by ([$$12 := %0->$$11]) decor ([]) {} -- |UNPARTITIONED|
assign [$$11] <- [function-call:
vxquery:{urn:org.apache.vxquery.operators-ext}id-from-node, Args:[%0->$$10]] --
|UNPARTITIONED|
unnest $$10 <- function-call:
vxquery:{urn:org.apache.vxquery.operators-ext}iterate, Args:[%0->$$6] --
|UNPARTITIONED|
nested tuple source -- |UNPARTITIONED|
} -- |UNPARTITIONED|
> GroupBy Operator Configured
> ---------------------------
>
> Key: VXQUERY-88
> URL: https://issues.apache.org/jira/browse/VXQUERY-88
> Project: VXQuery
> Issue Type: Sub-task
> Reporter: Preston Carman
> Assignee: Preston Carman
>
> The group by operator in the ConvertAssignSortDistinctNodesToOperatorsRule is
> not configured properly and crashes the program.
> INFO: Stopped ClusterControllerService
> Exception in thread "main"
> edu.uci.ics.hyracks.api.exceptions.HyracksException: Job Failed
> at
> edu.uci.ics.hyracks.control.cc.job.JobRun.waitForCompletion(JobRun.java:183)
> at
> edu.uci.ics.hyracks.control.cc.work.WaitForJobCompletionWork$1.run(WaitForJobCompletionWork.java:42)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:722)
> Caused by: edu.uci.ics.hyracks.api.exceptions.HyracksException: Exception
> caught by thread:
> edu.uci.ics.hyracks.dataflow.std.sort.ExternalSortOperatorDescriptor$SortActivity:TAID:TID:ANID:ODID:2:0:0:2:0
> edu.uci.ics.hyracks.api.exceptions.HyracksDataException:
> java.lang.IndexOutOfBoundsException
> at edu.uci.ics.hyracks.control.nc.Task.pushFrames(Task.java:336)
> at edu.uci.ics.hyracks.control.nc.Task.run(Task.java:267)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:722)
> Caused by: java.lang.IndexOutOfBoundsException
> at java.nio.Buffer.checkIndex(Buffer.java:538)
> at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:359)
> at
> edu.uci.ics.hyracks.dataflow.common.comm.io.FrameTupleAccessor.getFieldStartOffset(FrameTupleAccessor.java:75)
> at
> edu.uci.ics.hyracks.dataflow.std.sort.FrameSorter.sortFrames(FrameSorter.java:111)
> at
> edu.uci.ics.hyracks.dataflow.std.sort.ExternalSortRunGenerator.close(ExternalSortRunGenerator.java:64)
> at
> edu.uci.ics.hyracks.dataflow.std.sort.ExternalSortOperatorDescriptor$SortActivity$1.close(ExternalSortOperatorDescriptor.java:138)
> at edu.uci.ics.hyracks.control.nc.Task.pushFrames(Task.java:325)
> ... 4 more
> at
> edu.uci.ics.hyracks.control.cc.scheduler.JobScheduler.notifyTaskFailure(JobScheduler.java:614)
> at
> edu.uci.ics.hyracks.control.cc.work.TaskFailureWork.performEvent(TaskFailureWork.java:36)
> at
> edu.uci.ics.hyracks.control.cc.work.AbstractTaskLifecycleWork.run(AbstractTaskLifecycleWork.java:66)
> at
> edu.uci.ics.hyracks.control.common.work.WorkQueue$WorkerThread.run(WorkQueue.java:115)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira