ERROR: IndexOutOfBoundsException: Index: 0, Size: 0 - (Not work with more than 56 joins) v: 1.20.2
- Dominant language
- Java
- Stars
- 2k
- Forks
- 990
- Avg merge
- 1d 8h
- Merged PRs (30d)
- 5
Description
**Describe the bug**
2022-09-21 14:15:43,683 [qtp122612345-1489] ERROR o.a.d.e.server.rest.QueryResources - Query from Web UI Failed: {}
org.apache.drill.common.exceptions.UserRemoteException: SYSTEM ERROR: IndexOutOfBoundsException: Index: 0, Size: 0
Fragment: 0:0
Please, refer to logs for more information.
[Error Id: 679eeb99-cd35-480d-b4dc-20dcbffba2b8 on XXXXXXXXXXXXXXXXXXXXX]
at org.apache.drill.exec.server.rest.RestQueryRunner.submitQuery(RestQueryRunner.java:99)
at org.apache.drill.exec.server.rest.RestQueryRunner.run(RestQueryRunner.java:54)
at org.apache.drill.exec.server.rest.QueryResources.submitQuery(QueryResources.java:158)
at sun.reflect.GeneratedMethodAccessor267.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
**To Reproduce**
Steps to reproduce the behavior:
A query that worked in version 1.18 fails in version 1.20.2
The query has 66 joins that the previous version works, now the maximum it supports is 56.
We tried with 56 different joins and it works but going up to 57 fails.
**Expected behavior**
Work like the previous version
**Desktop (please complete the following information):**
- Version 1.20.2
**Additional context**
`2022-09-21 16:18:17,870 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,872 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,883 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,892 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,892 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,901 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,901 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,909 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,909 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,917 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,917 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,925 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,925 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,933 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,933 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,941 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,941 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,949 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,949 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,957 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,965 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,973 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,981 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,981 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,989 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,989 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,997 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,997 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,004 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,005 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,012 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,012 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,020 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,020 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,028 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,028 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,036 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,036 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,044 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,044 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,052 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,052 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,060 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,061 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,069 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,069 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,078 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,078 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,086 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,086 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,094 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,094 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,103 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,103 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,111 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,111 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,120 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,120 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,129 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,129 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,137 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,137 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,145 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,145 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,153 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,153 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,161 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,161 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,169 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,169 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,176 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,177 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,184 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,184 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,192 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,192 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,200 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,200 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,208 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,208 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,216 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,216 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,224 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,224 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,232 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,232 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,248 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,248 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,256 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,256 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,263 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,263 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,271 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,271 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,279 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,279 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,287 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,287 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,295 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,295 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,302 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,303 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,310 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,310 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,318 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,318 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,326 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,326 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,334 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State change requested AWAITING_ALLOCATION --> RUNNING
2022-09-21 16:18:18,334 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.f.FragmentStatusReporter - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State to report: RUNNING
2022-09-21 16:18:18,590 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] WARN o.a.d.e.p.r.impl.ResultSetLoaderImpl - Initial vector allocation: 39591936, but batch size limit is: 16777216
2022-09-21 16:18:19,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.physical.impl.BaseRootExec - Batch dump started: dumping last 2 failed batches
2022-09-21 16:18:19,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.p.i.p.ProjectRecordBatch - ProjectRecordBatch[projector=Projector[vector2=null, selectionVectorMode=NONE], hasRemainder=false, remainderIndex=0, recordCount=1684, container=org.apache.drill.exec.record.VectorContainer@6477fac3[recordCount = 1684, schemaChanged = false, schema = BatchSchema [fields=[[`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], [`T18¦¦DATE` (VARCHAR:OPTIONAL)], [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], [`OPERID` (VARCHAR:OPTIONAL)], [`SERVPOS` (VARCHAR:OPTIONAL)], [`NNUMPROV` (VARCHAR:OPTIONAL)], [`nifiExecutionId` (VARCHAR:OPTIONAL)]], selectionVector=NONE], wrappers = [org.apache.drill.exec.vector.NullableVarCharVector@7dac8e00[field = [`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@26ea0b56[field = [`T18¦¦DATE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@23b54f68[field = [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@78cf083f[field = [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@610a45a8[field = [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@17cc5264[field = [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e8b81fa[field = [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e85fce4[field = [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2d11cd99[field = [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@58bbe52d[field = [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1a7d2b91[field = [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2bae86e6[field = [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@870fb0f[field = [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@fe5f5a1[field = [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7cb7666f[field = [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@237156a9[field = [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2cd6694b[field = [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@c3ec98d[field = [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4bfd527b[field = [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@621081b3[field = [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7d93208b[field = [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@71bfc15[field = [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@26d40807[field = [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@402f0877[field = [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@245cff81[field = [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7cff544b[field = [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7aedffe3[field = [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@42393c79[field = [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@15a6348[field = [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7812224[field = [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1206d7d0[field = [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1957eb1d[field = [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4b458b5c[field = [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@45db1012[field = [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@61c7f72e[field = [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@476ee708[field = [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@20169bd2[field = [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3dd04442[field = [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6370aa51[field = [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@53165790[field = [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@474a9e2b[field = [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@788720d4[field = [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e433fb7[field = [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7f084138[field = [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@6c202334[field = [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@2d602fe4[field = [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@2ad90378[field = [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1765969a[field = [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7a312ec1[field = [`OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5682316c[field = [`SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@34222a07[field = [`NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@fc8ab5f[field = [`nifiExecutionId` (VARCHAR:OPTIONAL)], ...]], ...]]
2022-09-21 16:18:19,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.p.i.filter.FilterRecordBatch - FilterRecordBatch[container=org.apache.drill.exec.record.VectorContainer@7c7cdb41[recordCount = 1684, schemaChanged = false, schema = BatchSchema [fields=[[`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], [`T18¦¦DATE` (VARCHAR:OPTIONAL)], [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], [`OPERID` (VARCHAR:OPTIONAL)], [`SERVPOS` (VARCHAR:OPTIONAL)], [`NNUMPROV` (VARCHAR:OPTIONAL)], [`nifiExecutionId` (VARCHAR:OPTIONAL)]], selectionVector=TWO_BYTE], wrappers = [org.apache.drill.exec.vector.NullableVarCharVector@3bb28cf3[field = [`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e65fb90[field = [`T18¦¦DATE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@543d3950[field = [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4e015645[field = [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@61fb9e62[field = [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@507350b6[field = [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6db91451[field = [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@294ed4dd[field = [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@14fb5718[field = [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5ec753d1[field = [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7b79dfc4[field = [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@24ce144a[field = [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6ac3d45c[field = [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@efe4b0e[field = [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3b4c22ea[field = [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6ff41d8d[field = [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1b61451b[field = [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@67bbcb42[field = [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3d3afe2d[field = [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@72ed9472[field = [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@63355ea9[field = [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5aed6856[field = [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@30cc3eb0[field = [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2e1c62df[field = [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6715b1a3[field = [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@568bdacf[field = [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7634710[field = [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4aa4d7b9[field = [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@76ffe7[field = [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@8a31084[field = [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@15e58d47[field = [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7910895d[field = [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4eaed85f[field = [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5e99d63e[field = [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@672ff71f[field = [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1a08d0c6[field = [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@22dc8ff8[field = [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@32e485bb[field = [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2aeb1bf7[field = [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@76b9608c[field = [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@30dc82ec[field = [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@26030011[field = [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@54c58385[field = [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@69c53491[field = [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@3d5a00a7[field = [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@3e79c95[field = [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@7b46eec7[field = [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3be73c82[field = [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@56d54c61[field = [`OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@69e9611a[field = [`SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@25959a36[field = [`NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2714a12a[field = [`nifiExecutionId` (VARCHAR:OPTIONAL)], ...]], ...], selectionVector2=[SV2: recs=0 - ], filter=FilterTemplate2[outgoingSelectionVector=[SV2: recs=0 - ], incomingSelectionVector=null, svMode=NONE], popConfig=org.apache.drill.exec.physical.config.Filter@62450c57]
2022-09-21 16:18:19,241 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.physical.impl.BaseRootExec - Batch dump completed.
2022-09-21 16:18:19,241 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State change requested RUNNING --> FAILED
2022-09-21 16:18:19,252 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State change requested FAILED --> FINISHED
2022-09-21 16:18:19,253 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.w.fragment.FragmentExecutor - SYSTEM ERROR: IndexOutOfBoundsException: Index: 0, Size: 0
Fragment: 0:0
Please, refer to logs for more information.
[Error Id: 4cd0e872-c4ae-4a62-8c49-0e56fe2b65fc on apache-drill-01.pre.kio.veci.geci:31010]
org.apache.drill.common.exceptions.UserException: SYSTEM ERROR: IndexOutOfBoundsException: Index: 0, Size: 0
Fragment: 0:0
Please, refer to logs for more information.
[Error Id: 4cd0e872-c4ae-4a62-8c49-0e56fe2b65fc on apache-drill-01.pre.kio.veci.geci:31010]
at org.apache.drill.common.exceptions.UserException$Builder.build(UserException.java:657)
at org.apache.drill.exec.work.fragment.FragmentExecutor.sendFinalState(FragmentExecutor.java:392)
at org.apache.drill.exec.work.fragment.FragmentExecutor.cleanup(FragmentExecutor.java:244)
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:359)
at org.apache.drill.common.SelfCleaningRunnable.run(SelfCleaningRunnable.java:38)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
at java.util.ArrayList.rangeCheck(ArrayList.java:659)
at java.util.ArrayList.get(ArrayList.java:435)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupImplicitColumnRef(ProjectionMaterializer.java:316)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupExpression(ProjectionMaterializer.java:231)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setup(ProjectionMaterializer.java:155)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.generateProjector(ProjectionMaterializer.java:136)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchemaFromInput(ProjectRecordBatch.java:287)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchema(ProjectRecordBatch.java:265)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:92)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:103)
at org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:81)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:93)
at org.apache.drill.exec.work.fragment.FragmentExecutor.lambda$run$0(FragmentExecutor.java:321)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1762)
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:310)
... 4 common frames omitted
2022-09-21 16:18:19,258 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] WARN o.a.d.exec.rpc.control.WorkEventBus - Fragment 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0 manager is not found in the work bus.
2022-09-21 16:18:19,259 [qtp122612345-1815] ERROR o.a.d.e.server.rest.QueryResources - Query from Web UI Failed: {}
org.apache.drill.common.exceptions.UserRemoteException: SYSTEM ERROR: IndexOutOfBoundsException: Index: 0, Size: 0
Fragment: 0:0
Please, refer to logs for more information.
[Error Id: 4cd0e872-c4ae-4a62-8c49-0e56fe2b65fc on apache-drill-01.pre.kio.veci.geci:31010]
at org.apache.drill.exec.server.rest.RestQueryRunner.submitQuery(RestQueryRunner.java:99)
at org.apache.drill.exec.server.rest.RestQueryRunner.run(RestQueryRunner.java:54)
at org.apache.drill.exec.server.rest.QueryResources.submitQuery(QueryResources.java:158)
at sun.reflect.GeneratedMethodAccessor267.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$TypeOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:219)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:475)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:397)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:81)
at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:255)
at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:234)
at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680)
at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394)
at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346)
at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:366)
at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:319)
at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:205)
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
at org.eclipse.jetty.servlet.ServletHandler$ChainEnd.doFilter(ServletHandler.java:1631)
at org.apache.drill.exec.server.rest.header.ResponseHeadersSettingFilter.doFilter(ResponseHeadersSettingFilter.java:71)
at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601)
at org.apache.drill.exec.server.rest.CsrfTokenValidateFilter.doFilter(CsrfTokenValidateFilter.java:55)
at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601)
at org.apache.drill.exec.server.rest.CsrfTokenInjectFilter.doFilter(CsrfTokenInjectFilter.java:54)
at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601)
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:548)
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:571)
at org.apache.drill.exec.server.rest.auth.DrillHttpSecurityHandlerProvider.handle(DrillHttpSecurityHandlerProvider.java:163)
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235)
at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1434)
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501)
at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1349)
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
at org.eclipse.jetty.server.Server.handle(Server.java:516)
at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:400)
at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:645)
at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:392)
at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131)
at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409)
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
at .......(:0)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupImplicitColumnRef(ProjectionMaterializer.java:316)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupExpression(ProjectionMaterializer.java:231)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setup(ProjectionMaterializer.java:155)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.generateProjector(ProjectionMaterializer.java:136)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchemaFromInput(ProjectRecordBatch.java:287)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchema(ProjectRecordBatch.java:265)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:92)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:103)
at org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:81)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:93)
at org.apache.drill.exec.work.fragment.FragmentExecutor.lambda$run$0(FragmentExecutor.java:321)
at .......(:0)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1762)
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:310)
at org.apache.drill.common.SelfCleaningRunnable.run(SelfCleaningRunnable.java:38)
at .......(:0)
2022-09-21 16:18:19,289 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] WARN o.a.d.e.w.f.QueryStateProcessor - Dropping request to move to COMPLETED state as query is already at FAILED state (which is terminal).
`
`2022-09-21 16:18:17,870 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,872 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,883 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,892 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,892 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,901 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,901 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,909 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,909 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,917 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,917 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,925 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,925 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,933 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,933 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,941 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,941 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,949 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,949 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,957 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,965 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,973 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,981 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,981 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,989 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,989 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:17,997 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:17,997 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,004 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,005 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,012 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,012 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,020 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,020 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,028 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,028 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,036 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,036 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,044 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,044 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,052 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,052 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,060 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,061 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,069 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,069 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,078 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,078 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,086 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,086 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,094 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,094 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,103 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,103 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,111 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,111 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,120 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,120 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,129 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,129 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,137 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,137 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,145 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,145 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,153 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,153 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,161 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,161 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,169 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,169 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,176 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,177 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,184 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,184 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,192 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,192 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,200 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,200 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,208 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,208 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,216 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,216 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,224 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,224 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,232 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,232 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,248 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,248 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,256 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,256 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,263 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,263 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,271 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,271 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,279 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,279 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,287 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,287 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,295 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,295 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,302 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,303 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,310 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,310 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,318 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,318 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,326 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.s.m.MongoScanBatchCreator - Number of record readers initialized : 1
2022-09-21 16:18:18,326 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.p.impl.join.HashJoinBatch - Memory limit 200 MB bytes
2022-09-21 16:18:18,334 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State change requested AWAITING_ALLOCATION --> RUNNING
2022-09-21 16:18:18,334 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.f.FragmentStatusReporter - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State to report: RUNNING
2022-09-21 16:18:18,590 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] WARN o.a.d.e.p.r.impl.ResultSetLoaderImpl - Initial vector allocation: 39591936, but batch size limit is: 16777216
2022-09-21 16:18:19,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.physical.impl.BaseRootExec - Batch dump started: dumping last 2 failed batches
2022-09-21 16:18:19,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.p.i.p.ProjectRecordBatch - ProjectRecordBatch[projector=Projector[vector2=null, selectionVectorMode=NONE], hasRemainder=false, remainderIndex=0, recordCount=1684, container=org.apache.drill.exec.record.VectorContainer@6477fac3[recordCount = 1684, schemaChanged = false, schema = BatchSchema [fields=[[`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], [`T18¦¦DATE` (VARCHAR:OPTIONAL)], [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], [`OPERID` (VARCHAR:OPTIONAL)], [`SERVPOS` (VARCHAR:OPTIONAL)], [`NNUMPROV` (VARCHAR:OPTIONAL)], [`nifiExecutionId` (VARCHAR:OPTIONAL)]], selectionVector=NONE], wrappers = [org.apache.drill.exec.vector.NullableVarCharVector@7dac8e00[field = [`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@26ea0b56[field = [`T18¦¦DATE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@23b54f68[field = [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@78cf083f[field = [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@610a45a8[field = [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@17cc5264[field = [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e8b81fa[field = [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e85fce4[field = [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2d11cd99[field = [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@58bbe52d[field = [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1a7d2b91[field = [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2bae86e6[field = [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@870fb0f[field = [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@fe5f5a1[field = [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7cb7666f[field = [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@237156a9[field = [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2cd6694b[field = [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@c3ec98d[field = [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4bfd527b[field = [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@621081b3[field = [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7d93208b[field = [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@71bfc15[field = [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@26d40807[field = [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@402f0877[field = [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@245cff81[field = [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7cff544b[field = [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7aedffe3[field = [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@42393c79[field = [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@15a6348[field = [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7812224[field = [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1206d7d0[field = [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1957eb1d[field = [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4b458b5c[field = [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@45db1012[field = [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@61c7f72e[field = [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@476ee708[field = [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@20169bd2[field = [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3dd04442[field = [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6370aa51[field = [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@53165790[field = [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@474a9e2b[field = [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@788720d4[field = [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e433fb7[field = [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7f084138[field = [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@6c202334[field = [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@2d602fe4[field = [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@2ad90378[field = [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1765969a[field = [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7a312ec1[field = [`OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5682316c[field = [`SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@34222a07[field = [`NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@fc8ab5f[field = [`nifiExecutionId` (VARCHAR:OPTIONAL)], ...]], ...]]
2022-09-21 16:18:19,240 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.p.i.filter.FilterRecordBatch - FilterRecordBatch[container=org.apache.drill.exec.record.VectorContainer@7c7cdb41[recordCount = 1684, schemaChanged = false, schema = BatchSchema [fields=[[`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], [`T18¦¦DATE` (VARCHAR:OPTIONAL)], [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], [`OPERID` (VARCHAR:OPTIONAL)], [`SERVPOS` (VARCHAR:OPTIONAL)], [`NNUMPROV` (VARCHAR:OPTIONAL)], [`nifiExecutionId` (VARCHAR:OPTIONAL)]], selectionVector=TWO_BYTE], wrappers = [org.apache.drill.exec.vector.NullableVarCharVector@3bb28cf3[field = [`T18¦¦nifiExecutionId` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1e65fb90[field = [`T18¦¦DATE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@543d3950[field = [`T18¦¦EXPEDIENTE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4e015645[field = [`T18¦¦SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@61fb9e62[field = [`T18¦¦OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@507350b6[field = [`T18¦¦CNUMCIF1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6db91451[field = [`T18¦¦NGRUEMPR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@294ed4dd[field = [`T18¦¦CRAZONS1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@14fb5718[field = [`T18¦¦IBASETOT` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5ec753d1[field = [`T18¦¦NTIPOIVA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7b79dfc4[field = [`T18¦¦NPORCEIV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@24ce144a[field = [`T18¦¦IMPCUOTO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6ac3d45c[field = [`T18¦¦IMPBASEI` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@efe4b0e[field = [`T18¦¦IMCUOTAN` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3b4c22ea[field = [`T18¦¦IBASETAS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6ff41d8d[field = [`T18¦¦IMILLAEX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1b61451b[field = [`T18¦¦IMTASNSU` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@67bbcb42[field = [`T18¦¦IMTASEXE` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3d3afe2d[field = [`T18¦¦TFACTU76` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@72ed9472[field = [`T18¦¦NUMFACT1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@63355ea9[field = [`T18¦¦FGENER01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5aed6856[field = [`T18¦¦ITOTFA01` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@30cc3eb0[field = [`T18¦¦TFACTU02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2e1c62df[field = [`T18¦¦NUMFACT2` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@6715b1a3[field = [`T18¦¦FGENER02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@568bdacf[field = [`T18¦¦ITOTFA02` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7634710[field = [`T18¦¦TFACTU03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4aa4d7b9[field = [`T18¦¦NUMFACT3` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@76ffe7[field = [`T18¦¦FGENER03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@8a31084[field = [`T18¦¦ITOTFA03` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@15e58d47[field = [`T18¦¦IMTASA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@7910895d[field = [`T18¦¦IMIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@4eaed85f[field = [`T18¦¦IVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@5e99d63e[field = [`T18¦¦BASEFAR` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@672ff71f[field = [`T18¦¦BARETAX` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@1a08d0c6[field = [`T18¦¦ISIVA1` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@22dc8ff8[field = [`T18¦¦XTIPCAL` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@32e485bb[field = [`T18¦¦DSECCIO` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2aeb1bf7[field = [`T18¦¦NUPUKID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@76b9608c[field = [`T18¦¦XCANCELA` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@30dc82ec[field = [`T18¦¦NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@26030011[field = [`T18¦¦IMPSERVLIB` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@54c58385[field = [`T18¦¦XSWBONIF` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@69c53491[field = [`T18¦¦kafkaTopic` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@3d5a00a7[field = [`T18¦¦kafkaPartitionId` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@3e79c95[field = [`T18¦¦kafkaMsgOffset` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableBigIntVector@7b46eec7[field = [`T18¦¦kafkaMsgTimestamp` (BIGINT:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@3be73c82[field = [`T18¦¦kafkaMsgKey` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@56d54c61[field = [`OPERID` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@69e9611a[field = [`SERVPOS` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@25959a36[field = [`NNUMPROV` (VARCHAR:OPTIONAL)], ...], org.apache.drill.exec.vector.NullableVarCharVector@2714a12a[field = [`nifiExecutionId` (VARCHAR:OPTIONAL)], ...]], ...], selectionVector2=[SV2: recs=0 - ], filter=FilterTemplate2[outgoingSelectionVector=[SV2: recs=0 - ], incomingSelectionVector=null, svMode=NONE], popConfig=org.apache.drill.exec.physical.config.Filter@62450c57]
2022-09-21 16:18:19,241 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.physical.impl.BaseRootExec - Batch dump completed.
2022-09-21 16:18:19,241 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State change requested RUNNING --> FAILED
2022-09-21 16:18:19,252 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0: State change requested FAILED --> FINISHED
2022-09-21 16:18:19,253 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] ERROR o.a.d.e.w.fragment.FragmentExecutor - SYSTEM ERROR: IndexOutOfBoundsException: Index: 0, Size: 0
Fragment: 0:0
Please, refer to logs for more information.
[Error Id: 4cd0e872-c4ae-4a62-8c49-0e56fe2b65fc on XXXXXXXXXXXXXXXXXXXXXX]
org.apache.drill.common.exceptions.UserException: SYSTEM ERROR: IndexOutOfBoundsException: Index: 0, Size: 0
Fragment: 0:0
Please, refer to logs for more information.
[Error Id: 4cd0e872-c4ae-4a62-8c49-0e56fe2b65fc on XXXXXXXXXXXXXXXXXXXXXX]
at org.apache.drill.common.exceptions.UserException$Builder.build(UserException.java:657)
at org.apache.drill.exec.work.fragment.FragmentExecutor.sendFinalState(FragmentExecutor.java:392)
at org.apache.drill.exec.work.fragment.FragmentExecutor.cleanup(FragmentExecutor.java:244)
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:359)
at org.apache.drill.common.SelfCleaningRunnable.run(SelfCleaningRunnable.java:38)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
at java.util.ArrayList.rangeCheck(ArrayList.java:659)
at java.util.ArrayList.get(ArrayList.java:435)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupImplicitColumnRef(ProjectionMaterializer.java:316)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupExpression(ProjectionMaterializer.java:231)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setup(ProjectionMaterializer.java:155)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.generateProjector(ProjectionMaterializer.java:136)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchemaFromInput(ProjectRecordBatch.java:287)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchema(ProjectRecordBatch.java:265)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:92)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:103)
at org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:81)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:93)
at org.apache.drill.exec.work.fragment.FragmentExecutor.lambda$run$0(FragmentExecutor.java:321)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1762)
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:310)
... 4 common frames omitted
2022-09-21 16:18:19,258 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] WARN o.a.d.exec.rpc.control.WorkEventBus - Fragment 1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:0:0 manager is not found in the work bus.
2022-09-21 16:18:19,259 [qtp122612345-1815] ERROR o.a.d.e.server.rest.QueryResources - Query from Web UI Failed: {}
org.apache.drill.common.exceptions.UserRemoteException: SYSTEM ERROR: IndexOutOfBoundsException: Index: 0, Size: 0
Fragment: 0:0
Please, refer to logs for more information.
[Error Id: 4cd0e872-c4ae-4a62-8c49-0e56fe2b65fc on XXXXXXXXXXXXXXXXXXXXXX]
at org.apache.drill.exec.server.rest.RestQueryRunner.submitQuery(RestQueryRunner.java:99)
at org.apache.drill.exec.server.rest.RestQueryRunner.run(RestQueryRunner.java:54)
at org.apache.drill.exec.server.rest.QueryResources.submitQuery(QueryResources.java:158)
at sun.reflect.GeneratedMethodAccessor267.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$TypeOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:219)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:475)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:397)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:81)
at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:255)
at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:234)
at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680)
at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394)
at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346)
at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:366)
at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:319)
at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:205)
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
at org.eclipse.jetty.servlet.ServletHandler$ChainEnd.doFilter(ServletHandler.java:1631)
at org.apache.drill.exec.server.rest.header.ResponseHeadersSettingFilter.doFilter(ResponseHeadersSettingFilter.java:71)
at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601)
at org.apache.drill.exec.server.rest.CsrfTokenValidateFilter.doFilter(CsrfTokenValidateFilter.java:55)
at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601)
at org.apache.drill.exec.server.rest.CsrfTokenInjectFilter.doFilter(CsrfTokenInjectFilter.java:54)
at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601)
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:548)
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:571)
at org.apache.drill.exec.server.rest.auth.DrillHttpSecurityHandlerProvider.handle(DrillHttpSecurityHandlerProvider.java:163)
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235)
at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1434)
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501)
at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1349)
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
at org.eclipse.jetty.server.Server.handle(Server.java:516)
at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:400)
at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:645)
at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:392)
at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173)
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131)
at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409)
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
at .......(:0)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupImplicitColumnRef(ProjectionMaterializer.java:316)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setupExpression(ProjectionMaterializer.java:231)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.setup(ProjectionMaterializer.java:155)
at org.apache.drill.exec.physical.impl.project.ProjectionMaterializer.generateProjector(ProjectionMaterializer.java:136)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchemaFromInput(ProjectRecordBatch.java:287)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.setupNewSchema(ProjectRecordBatch.java:265)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:92)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractBinaryRecordBatch.prefetchFirstBatchFromBothSides(AbstractBinaryRecordBatch.java:99)
at org.apache.drill.exec.physical.impl.join.HashJoinBatch.buildSchema(HashJoinBatch.java:360)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:153)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:119)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:111)
at org.apache.drill.exec.record.AbstractUnaryRecordBatch.innerNext(AbstractUnaryRecordBatch.java:59)
at org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:85)
at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:170)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:103)
at org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:81)
at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:93)
at org.apache.drill.exec.work.fragment.FragmentExecutor.lambda$run$0(FragmentExecutor.java:321)
at .......(:0)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1762)
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:310)
at org.apache.drill.common.SelfCleaningRunnable.run(SelfCleaningRunnable.java:38)
at .......(:0)
2022-09-21 16:18:19,289 [1cd4c78b-0cca-1f38-3669-9fba1bd8e7b2:frag:0:0] WARN o.a.d.e.w.f.QueryStateProcessor - Dropping request to move to COMPLETED state as query is already at FAILED state (which is terminal).
`
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.