impala-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mostafa Mokhtar (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (IMPALA-5404) Queries with a large number of scan ranges can fail with Requested array size exceeds VM limit
Date Tue, 06 Jun 2017 20:47:18 GMT

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

Mostafa Mokhtar resolved IMPALA-5404.
-------------------------------------
    Resolution: Duplicate

> Queries with a large number of scan ranges can fail with Requested array size exceeds VM limit
> ----------------------------------------------------------------------------------------------
>
>                 Key: IMPALA-5404
>                 URL: https://issues.apache.org/jira/browse/IMPALA-5404
>             Project: IMPALA
>          Issue Type: Bug
>          Components: Frontend
>    Affects Versions: Impala 2.9.0
>            Reporter: Mostafa Mokhtar
>              Labels: bugbash-2017-05-31
>
> Exception
> {code}
> I0531 14:04:50.219782 80661 jni-util.cc:176] java.lang.OutOfMemoryError: Requested array size exceeds VM limit
> 	at java.util.Arrays.copyOf(Arrays.java:2271)
> 	at java.io.ByteArrayOutputStream.grow(ByteArrayOutputStream.java:113)
> 	at java.io.ByteArrayOutputStream.ensureCapacity(ByteArrayOutputStream.java:93)
> 	at java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:140)
> 	at org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTransport.java:145)
> 	at org.apache.thrift.protocol.TBinaryProtocol.writeByte(TBinaryProtocol.java:147)
> 	at org.apache.thrift.protocol.TBinaryProtocol.writeFieldStop(TBinaryProtocol.java:115)
> 	at org.apache.impala.thrift.TScanRangeLocationList$TScanRangeLocationListStandardScheme.write(TScanRangeLocationList.java:495)
> 	at org.apache.impala.thrift.TScanRangeLocationList$TScanRangeLocationListStandardScheme.write(TScanRangeLocationList.java:423)
> 	at org.apache.impala.thrift.TScanRangeLocationList.write(TScanRangeLocationList.java:363)
> 	at org.apache.impala.thrift.TPlanExecInfo$TPlanExecInfoStandardScheme.write(TPlanExecInfo.java:551)
> 	at org.apache.impala.thrift.TPlanExecInfo$TPlanExecInfoStandardScheme.write(TPlanExecInfo.java:450)
> 	at org.apache.impala.thrift.TPlanExecInfo.write(TPlanExecInfo.java:391)
> 	at org.apache.impala.thrift.TQueryExecRequest$TQueryExecRequestStandardScheme.write(TQueryExecRequest.java:1366)
> 	at org.apache.impala.thrift.TQueryExecRequest$TQueryExecRequestStandardScheme.write(TQueryExecRequest.java:1210)
> 	at org.apache.impala.thrift.TQueryExecRequest.write(TQueryExecRequest.java:1050)
> 	at org.apache.impala.thrift.TExecRequest$TExecRequestStandardScheme.write(TExecRequest.java:1382)
> 	at org.apache.impala.thrift.TExecRequest$TExecRequestStandardScheme.write(TExecRequest.java:1225)
> 	at org.apache.impala.thrift.TExecRequest.write(TExecRequest.java:1050)
> 	at org.apache.thrift.TSerializer.serialize(TSerializer.java:79)
> 	at org.apache.impala.service.JniFrontend.createExecRequest(JniFrontend.java:163)
> I0531 14:04:50.225301 80661 status.cc:122] OutOfMemoryError: Requested array size exceeds VM limit
>     @           0x83c119  impala::Status::Status()
>     @           0xb959b0  impala::JniUtil::GetJniExceptionMsg()
>     @           0xaa6a4b  impala::Frontend::GetExecRequest()
>     @           0xac1785  impala::ImpalaServer::ExecuteInternal()
>     @           0xac76f8  impala::ImpalaServer::Execute()
>     @           0xb04176  impala::ImpalaServer::query()
>     @           0xd6a1f5  beeswax::BeeswaxServiceProcessor::process_query()
>     @           0xd6d4f4  beeswax::BeeswaxServiceProcessor::dispatchCall()
>     @           0x80c36c  apache::thrift::TDispatchProcessor::process()
>     @          0x1b4937b  apache::thrift::server::TThreadPoolServer::Task::run()
>     @          0x1b30f39  apache::thrift::concurrency::ThreadManager::Worker::run()
>     @           0x9fb759  impala::ThriftThread::RunRunnable()
>     @           0x9fc1b2  boost::detail::function::void_function_obj_invoker0<>::invoke()
>     @           0xbec7d9  impala::Thread::SuperviseThread()
>     @           0xbed194  boost::detail::thread_data<>::run()
>     @           0xe540ea  (unknown)
>     @       0x3ce2a07aa1  (unknown)
>     @       0x3ce26e893d  (unknown)
> {code}
> Query
> {code}
> select * from (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a1, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a2, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a3, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a4, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a5, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a6, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a7, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a8, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a9, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a10, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a11, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a12, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a13, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a14, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a15, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a16, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a17, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a18, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a19, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a20, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a21, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a22, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a23, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a24, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a25, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a26, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a27, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a28, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a29, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a30, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a31, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a32, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a33, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a34, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a35, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a36, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a37, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a38, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a39, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a40, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a41, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a42, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a43, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a44, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a45, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a46, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a47, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a48, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a49, (select /* +straight_join */ count(*) from lineitem a join /* +shuffle */ orders b on a.l_orderkey = b.o_orderkey where a.l_orderkey = b.o_orderkey and l_shipdate between "1992-01-01" and "1994-01-01" and o_orderdate between "1992-01-01" and "1994-01-01" group by a.l_orderkey having count(*) > 9999999999) a50;
> {code}
> Plan
> {code}
>  +-------------------------------------------------------+
> | Explain String                                        |
> +-------------------------------------------------------+
> | Per-Host Resource Reservation: Memory=12.63GB         |
> | Per-Host Resource Estimates: Memory=116.24GB          |
> |                                                       |
> | PLAN-ROOT SINK                                        |
> | |                                                     |
> | 398:EXCHANGE [UNPARTITIONED]                          |
> | |                                                     |
> | 248:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--397:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  199:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  198:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--396:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  197:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  395:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  196:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 247:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--394:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  195:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  194:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--393:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  193:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  392:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  192:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 246:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--391:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  191:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  190:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--390:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  189:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  389:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  188:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 245:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--388:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  187:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  186:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--387:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  185:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  386:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  184:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 244:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--385:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  183:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  182:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--384:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  181:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  383:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  180:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 243:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--382:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  179:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  178:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--381:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  177:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  380:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  176:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 242:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--379:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  175:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  174:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--378:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  173:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  377:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  172:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 241:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--376:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  171:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  170:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--375:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  169:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  374:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  168:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 240:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--373:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  167:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  166:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--372:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  165:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  371:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  164:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 239:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--370:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  163:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  162:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--369:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  161:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  368:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  160:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 238:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--367:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  159:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  158:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--366:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  157:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  365:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  156:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 237:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--364:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  155:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  154:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--363:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  153:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  362:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  152:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 236:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--361:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  151:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  150:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--360:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  149:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  359:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  148:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 235:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--358:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  147:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  146:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--357:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  145:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  356:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  144:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 234:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--355:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  143:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  142:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--354:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  141:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  353:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  140:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 233:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--352:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  139:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  138:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--351:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  137:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  350:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  136:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 232:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--349:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  135:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  134:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--348:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  133:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  347:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  132:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 231:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--346:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  131:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  130:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--345:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  129:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  344:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  128:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 230:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--343:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  127:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  126:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--342:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  125:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  341:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  124:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 229:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--340:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  123:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  122:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--339:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  121:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  338:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  120:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 228:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--337:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  119:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  118:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--336:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  117:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  335:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  116:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 227:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--334:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  115:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  114:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--333:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  113:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  332:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  112:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 226:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--331:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  111:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  110:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--330:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  109:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  329:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  108:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 225:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--328:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  107:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  106:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--327:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  105:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  326:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  104:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 224:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--325:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  103:AGGREGATE [FINALIZE]                           |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  102:HASH JOIN [INNER JOIN, PARTITIONED]            |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--324:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  101:SCAN HDFS [tpch_1000_parquet.orders b]      |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  323:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  100:SCAN HDFS [tpch_1000_parquet.lineitem a]       |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 223:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--322:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  99:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  98:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--321:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  97:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  320:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  96:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 222:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--319:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  95:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  94:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--318:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  93:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  317:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  92:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 221:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--316:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  91:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  90:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--315:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  89:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  314:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  88:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 220:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--313:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  87:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  86:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--312:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  85:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  311:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  84:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 219:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--310:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  83:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  82:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--309:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  81:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  308:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  80:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 218:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--307:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  79:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  78:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--306:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  77:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  305:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  76:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 217:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--304:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  75:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  74:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--303:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  73:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  302:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  72:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 216:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--301:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  71:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  70:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--300:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  69:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  299:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  68:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 215:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--298:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  67:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  66:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--297:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  65:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  296:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  64:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 214:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--295:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  63:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  62:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--294:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  61:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  293:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  60:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 213:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--292:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  59:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  58:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--291:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  57:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  290:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  56:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 212:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--289:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  55:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  54:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--288:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  53:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  287:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  52:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 211:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--286:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  51:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  50:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--285:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  49:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  284:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  48:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 210:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--283:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  47:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  46:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--282:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  45:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  281:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  44:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 209:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--280:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  43:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  42:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |                                                  |
> | |  |--279:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  41:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  278:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  40:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |                                                     |
> | 208:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--277:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  39:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  38:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF009 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--276:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  37:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  275:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  36:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF009 -> a.l_orderkey          |
> | |                                                     |
> | 207:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--274:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  35:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  34:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF008 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--273:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  33:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  272:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  32:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF008 -> a.l_orderkey          |
> | |                                                     |
> | 206:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--271:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  31:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  30:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF007 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--270:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  29:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  269:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  28:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF007 -> a.l_orderkey          |
> | |                                                     |
> | 205:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--268:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  27:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  26:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF006 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--267:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  25:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  266:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  24:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF006 -> a.l_orderkey          |
> | |                                                     |
> | 204:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--265:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  23:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  22:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF005 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--264:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  21:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  263:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  20:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF005 -> a.l_orderkey          |
> | |                                                     |
> | 203:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--262:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  19:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  18:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF004 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--261:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  17:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> +-------------------------------------------------------+
> +-------------------------------------------------------+
> | Explain String                                        |
> +-------------------------------------------------------+
> | |  |                                                  |
> | |  260:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  16:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF004 -> a.l_orderkey          |
> | |                                                     |
> | 202:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--259:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  15:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  14:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF003 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--258:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  13:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  257:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  12:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF003 -> a.l_orderkey          |
> | |                                                     |
> | 201:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--256:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  11:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  10:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF002 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--255:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  09:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  254:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  08:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF002 -> a.l_orderkey          |
> | |                                                     |
> | 200:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]          |
> | |                                                     |
> | |--253:EXCHANGE [BROADCAST]                           |
> | |  |                                                  |
> | |  07:AGGREGATE [FINALIZE]                            |
> | |  |  output: count(*)                                |
> | |  |  group by: a.l_orderkey                          |
> | |  |  having: count(*) > 9999999999                   |
> | |  |                                                  |
> | |  06:HASH JOIN [INNER JOIN, PARTITIONED]             |
> | |  |  hash predicates: a.l_orderkey = b.o_orderkey    |
> | |  |  runtime filters: RF001 <- b.o_orderkey          |
> | |  |                                                  |
> | |  |--252:EXCHANGE [HASH(b.o_orderkey)]               |
> | |  |  |                                               |
> | |  |  05:SCAN HDFS [tpch_1000_parquet.orders b]       |
> | |  |     partitions=732/2406 files=98088 size=22.75GB |
> | |  |                                                  |
> | |  251:EXCHANGE [HASH(a.l_orderkey)]                  |
> | |  |                                                  |
> | |  04:SCAN HDFS [tpch_1000_parquet.lineitem a]        |
> | |     partitions=731/2526 files=97954 size=76.92GB    |
> | |     runtime filters: RF001 -> a.l_orderkey          |
> | |                                                     |
> | 03:AGGREGATE [FINALIZE]                               |
> | |  output: count(*)                                   |
> | |  group by: a.l_orderkey                             |
> | |  having: count(*) > 9999999999                      |
> | |                                                     |
> | 02:HASH JOIN [INNER JOIN, PARTITIONED]                |
> | |  hash predicates: a.l_orderkey = b.o_orderkey       |
> | |  runtime filters: RF000 <- b.o_orderkey             |
> | |                                                     |
> | |--250:EXCHANGE [HASH(b.o_orderkey)]                  |
> | |  |                                                  |
> | |  01:SCAN HDFS [tpch_1000_parquet.orders b]          |
> | |     partitions=732/2406 files=98088 size=22.75GB    |
> | |                                                     |
> | 249:EXCHANGE [HASH(a.l_orderkey)]                     |
> | |                                                     |
> | 00:SCAN HDFS [tpch_1000_parquet.lineitem a]           |
> |    partitions=731/2526 files=97954 size=76.92GB       |
> |    runtime filters: RF000 -> a.l_orderkey             |
> +-------------------------------------------------------+
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)


Mime
View raw message