[
https://issues.apache.org/jira/browse/DRILL-5732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16140973#comment-16140973
]
Robert Hou commented on DRILL-5732:
-----------------------------------
Yes, there is a Hash Agg step. The plan is:
{noformat}
| 00-00 Screen
00-01 ProjectAllowDup(EXPR$0=[$0], EXPR$1=[$1], EXPR$2=[$2], EXPR$3=[$3],
EXPR$4=[$4], EXPR$5=[$5], EXPR$6=[$6], EXPR$7=[$7], EXPR$8=[$8], EXPR$9=[$9],
EXPR$10=[$10], EXPR$11=[$11], EXPR$12=[$12], EXPR$13=[$13], EXPR$14=[$14],
EXPR$15=[$15], EXPR$16=[$16], EXPR$17=[$17], EXPR$18=[$18], EXPR$19=[$19],
EXPR$20=[$20], EXPR$21=[$21], EXPR$22=[$22], EXPR$23=[$23], EXPR$24=[$24],
EXPR$25=[$25], EXPR$26=[$26], EXPR$27=[$27], EXPR$28=[$28], EXPR$29=[$29],
EXPR$30=[$30], EXPR$31=[$31], EXPR$32=[$32], EXPR$33=[$33], EXPR$34=[$34],
EXPR$35=[$35], EXPR$36=[$36], EXPR$37=[$37], EXPR$38=[$38], EXPR$39=[$39],
EXPR$40=[$40], EXPR$41=[$41], EXPR$42=[$42], EXPR$43=[$43], EXPR$44=[$44],
EXPR$45=[$45], EXPR$46=[$46], EXPR$47=[$47], EXPR$48=[$48], EXPR$49=[$49],
c_email_address=[$50])
00-02 Project(EXPR$0=[$1], EXPR$1=[$2], EXPR$2=[$3], EXPR$3=[$4],
EXPR$4=[$5], EXPR$5=[$6], EXPR$6=[$7], EXPR$7=[$8], EXPR$8=[$9], EXPR$9=[$10],
EXPR$10=[$11], EXPR$11=[$12], EXPR$12=[$13], EXPR$13=[$14], EXPR$14=[$15],
EXPR$15=[$16], EXPR$16=[$17], EXPR$17=[$18], EXPR$18=[$19], EXPR$19=[$20],
EXPR$20=[$21], EXPR$21=[$22], EXPR$22=[$23], EXPR$23=[$24], EXPR$24=[$25],
EXPR$25=[$26], EXPR$26=[$27], EXPR$27=[$28], EXPR$28=[$29], EXPR$29=[$30],
EXPR$30=[$31], EXPR$31=[$32], EXPR$32=[$33], EXPR$33=[$34], EXPR$34=[$35],
EXPR$35=[$36], EXPR$36=[$37], EXPR$37=[$38], EXPR$38=[$39], EXPR$39=[$40],
EXPR$40=[$41], EXPR$41=[$42], EXPR$42=[$43], EXPR$43=[$44], EXPR$44=[$45],
EXPR$45=[$46], EXPR$46=[$47], EXPR$47=[$48], EXPR$48=[$49], EXPR$49=[$50],
ITEM=[$0])
00-03 HashAgg(group=[{0}], EXPR$0=[MAX($1)], EXPR$1=[MAX($2)],
EXPR$2=[MAX($3)], EXPR$3=[MAX($4)], EXPR$4=[MAX($5)], EXPR$5=[MAX($6)],
EXPR$6=[MAX($7)], EXPR$7=[MAX($8)], EXPR$8=[MAX($9)], EXPR$9=[MAX($10)],
EXPR$10=[MAX($11)], EXPR$11=[MAX($12)], EXPR$12=[MAX($13)], EXPR$13=[MAX($14)],
EXPR$14=[MAX($15)], EXPR$15=[MIN($16)], EXPR$16=[MAX($17)], EXPR$17=[MAX($18)],
EXPR$18=[MAX($19)], EXPR$19=[MAX($20)], EXPR$20=[MAX($21)], EXPR$21=[MAX($22)],
EXPR$22=[MAX($23)], EXPR$23=[MAX($24)], EXPR$24=[MIN($25)], EXPR$25=[MAX($26)],
EXPR$26=[MIN($27)], EXPR$27=[MIN($28)], EXPR$28=[MIN($29)], EXPR$29=[MAX($30)],
EXPR$30=[MAX($31)], EXPR$31=[MAX($32)], EXPR$32=[MIN($33)], EXPR$33=[MIN($34)],
EXPR$34=[MIN($35)], EXPR$35=[MIN($36)], EXPR$36=[MIN($37)], EXPR$37=[MAX($38)],
EXPR$38=[MAX($39)], EXPR$39=[MIN($40)], EXPR$40=[MIN($41)], EXPR$41=[MIN($42)],
EXPR$42=[MIN($43)], EXPR$43=[MIN($44)], EXPR$44=[MIN($45)], EXPR$45=[MIN($46)],
EXPR$46=[MAX($47)], EXPR$47=[MIN($48)], EXPR$48=[MIN($49)], EXPR$49=[MAX($50)])
00-04 Project(ITEM=[$1], col1=[$0], ITEM2=[$2], ITEM3=[$3],
ITEM4=[$4], ITEM5=[$5], ITEM6=[$6], ITEM7=[$7], ITEM8=[$8], ITEM9=[$9],
ITEM10=[$10], ITEM11=[$11], ITEM12=[$12], ITEM13=[$13], ITEM14=[$14],
ITEM15=[$15], ITEM16=[$16], ITEM17=[$17], ITEM18=[$18], ITEM19=[$19],
ITEM20=[$20], ITEM21=[$21], ITEM22=[$22], ITEM23=[$23], ITEM24=[$24],
ITEM25=[$25], ITEM26=[$26], ITEM27=[$27], ITEM28=[$28], ITEM29=[$29],
ITEM30=[$30], ITEM31=[$31], ITEM32=[$32], ITEM33=[$33], ITEM34=[$34],
ITEM35=[$35], ITEM36=[$36], $f37=[LENGTH($37)], ITEM38=[$38], ITEM39=[$39],
ITEM40=[$40], ITEM41=[$41], ITEM42=[$42], $f43=[LENGTH($43)],
$f44=[LENGTH($44)], $f45=[LENGTH($45)], $f46=[LENGTH($46)], ITEM47=[$47],
ITEM48=[$48], ITEM49=[$49], ITEM50=[$50])
00-05 SelectionVectorRemover
00-06 Filter(condition=[AND(>($0, 2536816), IS NOT NULL($1))])
00-07 Project(col1=[$0], ITEM=[ITEM($1, 'c_email_address')],
ITEM2=[ITEM($1, 'cs_sold_date_sk')], ITEM3=[ITEM($1, 'cs_sold_time_sk')],
ITEM4=[ITEM($1, 'cs_ship_date_sk')], ITEM5=[ITEM($1, 'cs_bill_customer_sk')],
ITEM6=[ITEM($1, 'cs_bill_cdemo_sk')], ITEM7=[ITEM($1, 'cs_bill_hdemo_sk')],
ITEM8=[ITEM($1, 'cs_bill_addr_sk')], ITEM9=[ITEM($1, 'cs_ship_customer_sk')],
ITEM10=[ITEM($1, 'cs_ship_cdemo_sk')], ITEM11=[ITEM($1, 'cs_ship_hdemo_sk')],
ITEM12=[ITEM($1, 'cs_ship_addr_sk')], ITEM13=[ITEM($1, 'cs_call_center_sk')],
ITEM14=[ITEM($1, 'cs_catalog_page_sk')], ITEM15=[ITEM($1, 'cs_ship_mode_sk')],
ITEM16=[ITEM($1, 'cs_warehouse_sk')], ITEM17=[ITEM($1, 'cs_item_sk')],
ITEM18=[ITEM($1, 'cs_promo_sk')], ITEM19=[ITEM($1, 'cs_order_number')],
ITEM20=[ITEM($1, 'cs_quantity')], ITEM21=[ITEM($1, 'cs_wholesale_cost')],
ITEM22=[ITEM($1, 'cs_list_price')], ITEM23=[ITEM($1, 'cs_sales_price')],
ITEM24=[ITEM($1, 'cs_ext_discount_amt')], ITEM25=[ITEM($1,
'cs_ext_sales_price')], ITEM26=[ITEM($1, 'cs_ext_wholesale_cost')],
ITEM27=[ITEM($1, 'cs_ext_list_price')], ITEM28=[ITEM($1, 'cs_ext_tax')],
ITEM29=[ITEM($1, 'cs_coupon_amt')], ITEM30=[ITEM($1, 'cs_ext_ship_cost')],
ITEM31=[ITEM($1, 'cs_net_paid')], ITEM32=[ITEM($1, 'cs_net_paid_inc_tax')],
ITEM33=[ITEM($1, 'cs_net_paid_inc_ship')], ITEM34=[ITEM($1,
'cs_net_paid_inc_ship_tax')], ITEM35=[ITEM($1, 'cs_net_profit')],
ITEM36=[ITEM($1, 'c_customer_sk')], ITEM37=[ITEM($1, 'c_customer_id')],
ITEM38=[ITEM($1, 'c_current_cdemo_sk')], ITEM39=[ITEM($1,
'c_current_hdemo_sk')], ITEM40=[ITEM($1, 'c_current_addr_sk')],
ITEM41=[ITEM($1, 'c_first_shipto_date_sk')], ITEM42=[ITEM($1,
'c_first_sales_date_sk')], ITEM43=[ITEM($1, 'c_salutation')], ITEM44=[ITEM($1,
'c_first_name')], ITEM45=[ITEM($1, 'c_last_name')], ITEM46=[ITEM($1,
'c_preferred_cust_flag')], ITEM47=[ITEM($1, 'c_birth_day')], ITEM48=[ITEM($1,
'c_birth_month')], ITEM49=[ITEM($1, 'c_birth_year')], ITEM50=[ITEM($1,
'c_last_review_date')])
00-08 SelectionVectorRemover
00-09 Sort(sort0=[$2], dir0=[ASC-nulls-first])
00-10 Project(col1=[+($1, $2)], T2¦¦*=[$0],
c_email_address=[$3])
00-11 Project(T2¦¦*=[$0], cs_sold_date_sk=[$1],
cs_sold_time_sk=[$2], c_email_address=[$3])
00-12 Scan(groupscan=[ParquetGroupScan
[entries=[ReadEntryWithPath
[path=maprfs:///drill/testdata/resource-manager/md1362]],
selectionRoot=maprfs:/drill/testdata/resource-manager/md1362, numFiles=1,
usedMetadataFile=false, columns=[`*`]]])
{noformat}
I will adjust the memory setting.
> Unable to allocate sv2 for 9039 records, and not enough batchGroups to spill.
> -----------------------------------------------------------------------------
>
> Key: DRILL-5732
> URL: https://issues.apache.org/jira/browse/DRILL-5732
> Project: Apache Drill
> Issue Type: Bug
> Affects Versions: 1.10.0
> Reporter: Robert Hou
> Assignee: Paul Rogers
> Attachments: 26621eb2-daec-cef9-efed-5986e72a750a.sys.drill,
> drillbit.log.83
>
>
> git commit id:
> {noformat}
> | 1.12.0-SNAPSHOT | e9065b55ea560e7f737d6fcb4948f9e945b9b14f | DRILL-5660:
> Parquet metadata caching improvements | 15.08.2017 @ 09:31:00 PDT |
> [email protected] | 15.08.2017 @ 13:29:26 PDT |
> {noformat}
> Query is:
> {noformat}
> ALTER SESSION SET `exec.sort.disable_managed` = false;
> alter session set `planner.disable_exchanges` = true;
> alter session set `planner.memory.max_query_memory_per_node` = 104857600;
> alter session set `planner.width.max_per_node` = 1;
> alter session set `planner.width.max_per_query` = 1;
> select max(col1), max(cs_sold_date_sk), max(cs_sold_time_sk),
> max(cs_ship_date_sk), max(cs_bill_customer_sk), max(cs_bill_cdemo_sk),
> max(cs_bill_hdemo_sk), max(cs_bill_addr_sk), max(cs_ship_customer_sk),
> max(cs_ship_cdemo_sk), max(cs_ship_hdemo_sk), max(cs_ship_addr_sk),
> max(cs_call_center_sk), max(cs_catalog_page_sk), max(cs_ship_mode_sk),
> min(cs_warehouse_sk), max(cs_item_sk), max(cs_promo_sk),
> max(cs_order_number), max(cs_quantity), max(cs_wholesale_cost),
> max(cs_list_price), max(cs_sales_price), max(cs_ext_discount_amt),
> min(cs_ext_sales_price), max(cs_ext_wholesale_cost), min(cs_ext_list_price),
> min(cs_ext_tax), min(cs_coupon_amt), max(cs_ext_ship_cost), max(cs_net_paid),
> max(cs_net_paid_inc_tax), min(cs_net_paid_inc_ship),
> min(cs_net_paid_inc_ship_tax), min(cs_net_profit), min(c_customer_sk),
> min(length(c_customer_id)), max(c_current_cdemo_sk), max(c_current_hdemo_sk),
> min(c_current_addr_sk), min(c_first_shipto_date_sk),
> min(c_first_sales_date_sk), min(length(c_salutation)),
> min(length(c_first_name)), min(length(c_last_name)),
> min(length(c_preferred_cust_flag)), max(c_birth_day), min(c_birth_month),
> min(c_birth_year), max(c_last_review_date), c_email_address from (select
> cs_sold_date_sk+cs_sold_time_sk col1, * from
> dfs.`/drill/testdata/resource-manager/md1362` order by c_email_address nulls
> first) d where d.col1 > 2536816 and c_email_address is not null group by
> c_email_address;
> ALTER SESSION SET `exec.sort.disable_managed` = true;
> alter session set `planner.disable_exchanges` = false;
> alter session set `planner.memory.max_query_memory_per_node` = 2147483648;
> alter session set `planner.width.max_per_node` = 17;
> alter session set `planner.width.max_per_query` = 1000;
> {noformat}
> Here is the stack trace:
> {noformat}
> 2017-08-18 13:15:27,052 [2668b522-5833-8fd2-0b6d-e685197f0ae3:frag:0:0] DEBUG
> o.a.d.e.t.g.SingleBatchSorterGen27 - Took 6445 us to sort 9039 records
> 2017-08-18 13:15:27,420 [2668b522-5833-8fd2-0b6d-e685197f0ae3:frag:0:0] DEBUG
> o.a.d.e.p.i.xsort.ExternalSortBatch - Copier allocator current allocation 0
> 2017-08-18 13:15:27,420 [2668b522-5833-8fd2-0b6d-e685197f0ae3:frag:0:0] DEBUG
> o.a.d.e.p.i.xsort.ExternalSortBatch - mergeAndSpill: starting total size in
> memory = 71964288
> 2017-08-18 13:15:27,421 [2668b522-5833-8fd2-0b6d-e685197f0ae3:frag:0:0] INFO
> o.a.d.e.p.i.xsort.ExternalSortBatch - User Error Occurred: One or more nodes
> ran out of memory while executing the query.
> org.apache.drill.common.exceptions.UserException: RESOURCE ERROR: One or more
> nodes ran out of memory while executing the query.
> Unable to allocate sv2 for 9039 records, and not enough batchGroups to spill.
> batchGroups.size 1
> spilledBatchGroups.size 0
> allocated memory 71964288
> allocator limit 52428800
> [Error Id: 7b248f12-2b31-4013-86b6-92e6c842db48 ]
> at
> org.apache.drill.common.exceptions.UserException$Builder.build(UserException.java:550)
> ~[drill-common-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.xsort.ExternalSortBatch.newSV2(ExternalSortBatch.java:637)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.xsort.ExternalSortBatch.innerNext(ExternalSortBatch.java:379)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:109)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:51)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.svremover.RemovingRecordBatch.innerNext(RemovingRecordBatch.java:93)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:109)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:51)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:133)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:109)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:51)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:109)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:51)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.svremover.RemovingRecordBatch.innerNext(RemovingRecordBatch.java:93)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:109)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:51)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:133)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.test.generated.HashAggregatorGen24.doWork(HashAggTemplate.java:568)
> [na:na]
> at
> org.apache.drill.exec.physical.impl.aggregate.HashAggBatch.innerNext(HashAggBatch.java:168)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:109)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:51)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:133)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:109)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:51)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:133)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:164)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:225)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:105)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:81)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:95)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.work.fragment.FragmentExecutor$1.run(FragmentExecutor.java:234)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.exec.work.fragment.FragmentExecutor$1.run(FragmentExecutor.java:227)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at java.security.AccessController.doPrivileged(Native Method)
> [na:1.7.0_111]
> at javax.security.auth.Subject.doAs(Subject.java:415) [na:1.7.0_111]
> at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1595)
> [hadoop-common-2.7.0-mapr-1607.jar:na]
> at
> org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:227)
> [drill-java-exec-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> org.apache.drill.common.SelfCleaningRunnable.run(SelfCleaningRunnable.java:38)
> [drill-common-1.12.0-SNAPSHOT.jar:1.12.0-SNAPSHOT]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> [na:1.7.0_111]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> [na:1.7.0_111]
> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_111]
> 2017-08-18 13:15:27,421 [2668b522-5833-8fd2-0b6d-e685197f0ae3:frag:0:0] INFO
> o.a.d.e.w.fragment.FragmentExecutor -
> 2668b522-5833-8fd2-0b6d-e685197f0ae3:0:0: State change requested RUNNING -->
> FAILED
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
