[
https://issues.apache.org/jira/browse/DRILL-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14050921#comment-14050921
]
Ramana Inukonda Nagaraj commented on DRILL-1101:
------------------------------------------------
2014-07-03 00:32:50,260 [933371c9-d621-43a7-b40d-fa5fb9538aaa:foreman] ERROR
o.a.drill.exec.work.foreman.Foreman - Error
952c4bdd-e6bc-4fa8-ba0c-c22e0b7f76d7: Failure while parsing sql.
org.eigenbase.relopt.RelOptPlanner$CannotPlanException: Node
[rel#88257:Subset#11.LOGICAL.ANY([]).[]] could not be implemented; planner
state:
{code}
Root: rel#88257:Subset#11.LOGICAL.ANY([]).[]
Original rel:
AbstractConverter(subset=[rel#88255:Subset#12.LOGICAL.ANY([]).[]],
convention=[LOGICAL], DrillDistributionTraitDef=[ANY([])], sort=[[]]): rowcount
= 1.7976931348623157E308, cumulative cost = {inf}, id = 88256
ProjectRel(subset=[rel#88254:Subset#12.NONE.ANY([]).[]],
technology_type=[$0], organization=[$1], metric_no=[$2], metric_name=[$3],
metric_value=[$4]): rowcount = 1.7976931348623157E308, cumulative cost =
{1.7976931348623157E308 rows, Infinity cpu, 0.0 io, 0.0 network}, id = 88253
UnionRel(subset=[rel#88252:Subset#11.NONE.ANY([]).[]], all=[true]):
rowcount = 1.7976931348623157E308, cumulative cost = {1.7976931348623157E308
rows, 1.7976931348623157E308 cpu, 0.0 io, 0.0 network}, id = 88251
ProjectRel(subset=[rel#88242:Subset#6.NONE.ANY([]).[]],
technology_type=['emails'], organization=[$0], metric_no=[1],
metric_name=['email_count'], metric_value=[*(2, $1)]): rowcount =
1.7976931348623157E308, cumulative cost = {1.7976931348623157E308 rows,
Infinity cpu, 0.0 io, 0.0 network}, id = 88241
AggregateRel(subset=[rel#88240:Subset#5.NONE.ANY([]).[]], group=[{0}],
agg#0=[COUNT(DISTINCT $1)]): rowcount = 1.7976931348623158E307, cumulative cost
= {1.7976931348623158E307 rows, 0.0 cpu, 0.0 io, 0.0 network}, id = 88239
ProjectRel(subset=[rel#88238:Subset#4.NONE.ANY([]).[]],
organization=[$29], message_id=[$10]): rowcount = 1.7976931348623157E308,
cumulative cost = {1.7976931348623157E308 rows, Infinity cpu, 0.0 io, 0.0
network}, id = 88237
FilterRel(subset=[rel#88236:Subset#3.NONE.ANY([]).[]],
condition=[=($8, 'RECEIVE')]): rowcount = 2.6965397022934733E307, cumulative
cost = {2.6965397022934733E307 rows, 1.7976931348623157E308 cpu, 0.0 io, 0.0
network}, id = 88235
JoinRel(subset=[rel#88234:Subset#2.NONE.ANY([]).[]],
condition=[=($18, $38)], joinType=[left]): rowcount = 1500.0, cumulative cost =
{1500.0 rows, 0.0 cpu, 0.0 io, 0.0 network}, id = 88233
EnumerableTableAccessRel(subset=[rel#88231:Subset#0.ENUMERABLE.ANY([]).[]],
table=[[hive, ona_emails]]): rowcount = 100.0, cumulative cost = {100.0 rows,
101.0 cpu, 0.0 io, 0.0 network}, id = 88217
EnumerableTableAccessRel(subset=[rel#88232:Subset#1.ENUMERABLE.ANY([]).[]],
table=[[hive, ona_employee_table]]): rowcount = 100.0, cumulative cost = {100.0
rows, 101.0 cpu, 0.0 io, 0.0 network}, id = 88218
ProjectRel(subset=[rel#88250:Subset#10.NONE.ANY([]).[]],
technology_type=['emails'], organization=[$0], metric_no=[2],
metric_name=['email_active_employee_count'], metric_value=[$1]): rowcount =
1.7976931348623157E308, cumulative cost = {1.7976931348623157E308 rows,
Infinity cpu, 0.0 io, 0.0 network}, id = 88249
AggregateRel(subset=[rel#88248:Subset#9.NONE.ANY([]).[]], group=[{0}],
metric_value=[COUNT()]): rowcount = 1.7976931348623158E307, cumulative cost =
{1.7976931348623158E307 rows, 0.0 cpu, 0.0 io, 0.0 network}, id = 88247
ProjectRel(subset=[rel#88246:Subset#8.NONE.ANY([]).[]],
organization=[$1]): rowcount = 1.7976931348623157E308, cumulative cost =
{1.7976931348623157E308 rows, 1.7976931348623157E308 cpu, 0.0 io, 0.0 network},
id = 88245
FilterRel(subset=[rel#88244:Subset#7.NONE.ANY([]).[]],
condition=[=($4, 'A')]): rowcount = 15.0, cumulative cost = {15.0 rows, 100.0
cpu, 0.0 io, 0.0 network}, id = 88243
EnumerableTableAccessRel(subset=[rel#88232:Subset#1.ENUMERABLE.ANY([]).[]],
table=[[hive, ona_employee_table]]): rowcount = 100.0, cumulative cost = {100.0
rows, 101.0 cpu, 0.0 io, 0.0 network}, id = 88218
Sets:
Set#0, type: RecordType(VARCHAR(65535) date_time, VARCHAR(65535) client_ip,
VARCHAR(65535) client_hostname, VARCHAR(65535) server_ip, VARCHAR(65535)
server_hostname, VARCHAR(65535) source_context, VARCHAR(65535) connector_id,
VARCHAR(65535) source, VARCHAR(65535) event_id, VARCHAR(65535)
internal_message_id, VARCHAR(65535) message_id, VARCHAR(65535)
recipient_address, VARCHAR(65535) recipient_status, INTEGER total_bytes,
INTEGER recipient_count, VARCHAR(65535) related_recipient_address,
VARCHAR(65535) reference, VARCHAR(65535) message_subject, VARCHAR(65535)
sender_address, VARCHAR(65535) return_path, VARCHAR(65535) message_info,
VARCHAR(65535) directionality, VARCHAR(65535) tenant_id, VARCHAR(65535)
original_client_ip, VARCHAR(65535) original_server_ip, VARCHAR(65535)
custom_data, VARCHAR(65535) emailfilename, TIMESTAMP(0) load_dt)
rel#88231:Subset#0.ENUMERABLE.ANY([]).[], best=rel#88217,
importance=0.4782969000000001
rel#88217:EnumerableTableAccessRel.ENUMERABLE.ANY([]).[](table=[hive,
ona_emails]), rowcount=100.0, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io,
0.0 network}
rel#88410:AbstractConverter.ENUMERABLE.ANY([]).[](child=rel#88409:Subset#0.LOGICAL.ANY([]).[],convention=ENUMERABLE,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=3.0, cumulative cost={inf}
rel#88409:Subset#0.LOGICAL.ANY([]).[], best=rel#88509,
importance=0.4304672100000001
rel#88411:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88231:Subset#0.ENUMERABLE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=100.0, cumulative cost={inf}
rel#88509:DrillScanRel.LOGICAL.ANY([]).[](table=[hive,
ona_emails],groupscan=HiveScan [table=Table(tableName:ona_emails,
dbName:default, owner:root, createTime:1404254613, lastAccessTime:0,
retention:0, sd:StorageDescriptor(cols:[FieldSchema(name:date_time,
type:string, comment:null), FieldSchema(name:client_ip, type:string,
comment:null), FieldSchema(name:client_hostname, type:string, comment:null),
FieldSchema(name:server_ip, type:string, comment:null),
FieldSchema(name:server_hostname, type:string, comment:null),
FieldSchema(name:source_context, type:string, comment:null),
FieldSchema(name:connector_id, type:string, comment:null),
FieldSchema(name:source, type:string, comment:null), FieldSchema(name:event_id,
type:string, comment:null), FieldSchema(name:internal_message_id, type:string,
comment:null), FieldSchema(name:message_id, type:string, comment:null),
FieldSchema(name:recipient_address, type:string, comment:null),
FieldSchema(name:recipient_status, type:string, comment:null),
FieldSchema(name:total_bytes, type:int, comment:null),
FieldSchema(name:recipient_count, type:int, comment:null),
FieldSchema(name:related_recipient_address, type:string, comment:null),
FieldSchema(name:reference, type:string, comment:null),
FieldSchema(name:message_subject, type:string, comment:null),
FieldSchema(name:sender_address, type:string, comment:null),
FieldSchema(name:return_path, type:string, comment:null),
FieldSchema(name:message_info, type:string, comment:null),
FieldSchema(name:directionality, type:string, comment:null),
FieldSchema(name:tenant_id, type:string, comment:null),
FieldSchema(name:original_client_ip, type:string, comment:null),
FieldSchema(name:original_server_ip, type:string, comment:null),
FieldSchema(name:custom_data, type:string, comment:null),
FieldSchema(name:emailfilename, type:string, comment:null),
FieldSchema(name:load_dt, type:timestamp, comment:null)],
location:maprfs:/user/hive/warehouse/ona_emails,
inputFormat:org.apache.hadoop.mapred.TextInputFormat,
outputFormat:org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat,
compressed:false, numBuckets:-1, serdeInfo:SerDeInfo(name:null,
serializationLib:org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe,
parameters:{serialization.format= , field.delim= , line.delim=
}), bucketCols:[], sortCols:[], parameters:{},
skewedInfo:SkewedInfo(skewedColNames:[], skewedColValues:[],
skewedColValueLocationMaps:{}), storedAsSubDirectories:false),
partitionKeys:[], parameters:{transient_lastDdlTime=1404254613},
viewOriginalText:null, viewExpandedText:null, tableType:MANAGED_TABLE),
inputSpError: exception while executing query (state=,code=0)
lits=[maprfs:/user/hive/warehouse/ona_emails/ona_emails:0+3303],
columns=null]), rowcount=3.0, cumulative cost={3.0 rows, 84.0 cpu, 0.0 io, 0.0
network}
Set#1, type: RecordType(VARCHAR(65535) userid, VARCHAR(65535) organization,
VARCHAR(65535) hierarchy, VARCHAR(65535) title, VARCHAR(65535) status,
VARCHAR(65535) country, VARCHAR(65535) workphone, VARCHAR(65535) mobilephone,
VARCHAR(65535) work_type, VARCHAR(65535) employee_type, VARCHAR(65535) emailid)
rel#88232:Subset#1.ENUMERABLE.ANY([]).[], best=rel#88218,
importance=0.4782969000000001
rel#88218:EnumerableTableAccessRel.ENUMERABLE.ANY([]).[](table=[hive,
ona_employee_table]), rowcount=100.0, cumulative cost={100.0 rows, 101.0 cpu,
0.0 io, 0.0 network}
rel#88365:AbstractConverter.ENUMERABLE.ANY([]).[](child=rel#88364:Subset#1.LOGICAL.ANY([]).[],convention=ENUMERABLE,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.0, cumulative cost={inf}
rel#88364:Subset#1.LOGICAL.ANY([]).[], best=rel#88508,
importance=0.4304672100000001
rel#88366:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88232:Subset#1.ENUMERABLE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=100.0, cumulative cost={inf}
rel#88508:DrillScanRel.LOGICAL.ANY([]).[](table=[hive,
ona_employee_table],groupscan=HiveScan
[table=Table(tableName:ona_employee_table, dbName:default, owner:root,
createTime:1404334977, lastAccessTime:0, retention:0,
sd:StorageDescriptor(cols:[FieldSchema(name:userid, type:string, comment:null),
FieldSchema(name:organization, type:string, comment:null),
FieldSchema(name:hierarchy, type:string, comment:null), FieldSchema(name:title,
type:string, comment:null), FieldSchema(name:status, type:string,
comment:null), FieldSchema(name:country, type:string, comment:null),
FieldSchema(name:workphone, type:string, comment:null),
FieldSchema(name:mobilephone, type:string, comment:null),
FieldSchema(name:work_type, type:string, comment:null),
FieldSchema(name:employee_type, type:string, comment:null),
FieldSchema(name:emailid, type:string, comment:null)],
location:maprfs:/user/hive/warehouse/ona_employee_table,
inputFormat:org.apache.hadoop.mapred.TextInputFormat,
outputFormat:org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat,
compressed:false, numBuckets:-1, serdeInfo:SerDeInfo(name:null,
serializationLib:org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe,
parameters:{serialization.format=, field.delim=, line.delim=
}), bucketCols:[], sortCols:[], parameters:{},
skewedInfo:SkewedInfo(skewedColNames:[], skewedColValues:[],
skewedColValueLocationMaps:{}), storedAsSubDirectories:false),
partitionKeys:[], parameters:{numPartitions=0, numFiles=1,
transient_lastDdlTime=1404346226, numRows=0, totalSize=797, rawDataSize=0},
viewOriginalText:null, viewExpandedText:null, tableType:MANAGED_TABLE),
inputSplits=[maprfs:/user/hive/warehouse/ona_employee_table/000000_0:0+797],
columns=null]), rowcount=1.0, cumulative cost={tiny}
Set#2, type: RecordType(VARCHAR(65535) date_time, VARCHAR(65535) client_ip,
VARCHAR(65535) client_hostname, VARCHAR(65535) server_ip, VARCHAR(65535)
server_hostname, VARCHAR(65535) source_context, VARCHAR(65535) connector_id,
VARCHAR(65535) source, VARCHAR(65535) event_id, VARCHAR(65535)
internal_message_id, VARCHAR(65535) message_id, VARCHAR(65535)
recipient_address, VARCHAR(65535) recipient_status, INTEGER total_bytes,
INTEGER recipient_count, VARCHAR(65535) related_recipient_address,
VARCHAR(65535) reference, VARCHAR(65535) message_subject, VARCHAR(65535)
sender_address, VARCHAR(65535) return_path, VARCHAR(65535) message_info,
VARCHAR(65535) directionality, VARCHAR(65535) tenant_id, VARCHAR(65535)
original_client_ip, VARCHAR(65535) original_server_ip, VARCHAR(65535)
custom_data, VARCHAR(65535) emailfilename, TIMESTAMP(0) load_dt, VARCHAR(65535)
userid, VARCHAR(65535) organization, VARCHAR(65535) hierarchy, VARCHAR(65535)
title, VARCHAR(65535) status, VARCHAR(65535) country, VARCHAR(65535) workphone,
VARCHAR(65535) mobilephone, VARCHAR(65535) work_type, VARCHAR(65535)
employee_type, VARCHAR(65535) emailid)
rel#88234:Subset#2.NONE.ANY([]).[], best=null, importance=0.531441
rel#88233:JoinRel.NONE.ANY([]).[](left=rel#88231:Subset#0.ENUMERABLE.ANY([]).[],right=rel#88232:Subset#1.ENUMERABLE.ANY([]).[],condition==($18,
$38),joinType=left), rowcount=1500.0, cumulative cost={inf}
rel#88489:Subset#2.LOGICAL.ANY([]).[], best=rel#88507,
importance=0.4292452830188679
rel#88490:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88234:Subset#2.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88507:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#88409:Subset#0.LOGICAL.ANY([]).[],right=rel#88364:Subset#1.LOGICAL.ANY([]).[],condition==($18,
$38),joinType=left), rowcount=3.0, cumulative cost={5.0 rows, 86.0 cpu, 0.0
io, 0.0 network}
Set#3, type: RecordType(VARCHAR(65535) date_time, VARCHAR(65535) client_ip,
VARCHAR(65535) client_hostname, VARCHAR(65535) server_ip, VARCHAR(65535)
server_hostname, VARCHAR(65535) source_context, VARCHAR(65535) connector_id,
VARCHAR(65535) source, VARCHAR(65535) event_id, VARCHAR(65535)
internal_message_id, VARCHAR(65535) message_id, VARCHAR(65535)
recipient_address, VARCHAR(65535) recipient_status, INTEGER total_bytes,
INTEGER recipient_count, VARCHAR(65535) related_recipient_address,
VARCHAR(65535) reference, VARCHAR(65535) message_subject, VARCHAR(65535)
sender_address, VARCHAR(65535) return_path, VARCHAR(65535) message_info,
VARCHAR(65535) directionality, VARCHAR(65535) tenant_id, VARCHAR(65535)
original_client_ip, VARCHAR(65535) original_server_ip, VARCHAR(65535)
custom_data, VARCHAR(65535) emailfilename, TIMESTAMP(0) load_dt, VARCHAR(65535)
userid, VARCHAR(65535) organization, VARCHAR(65535) hierarchy, VARCHAR(65535)
title, VARCHAR(65535) status, VARCHAR(65535) country, VARCHAR(65535) workphone,
VARCHAR(65535) mobilephone, VARCHAR(65535) work_type, VARCHAR(65535)
employee_type, VARCHAR(65535) emailid)
rel#88236:Subset#3.NONE.ANY([]).[], best=null,
importance=0.5904900000000001
rel#88235:FilterRel.NONE.ANY([]).[](child=rel#88234:Subset#2.NONE.ANY([]).[],condition==($8,
'RECEIVE')), rowcount=2.6965397022934733E307, cumulative cost={inf}
rel#88335:JoinRel.NONE.ANY([]).[](left=rel#88334:Subset#19.NONE.ANY([]).[],right=rel#88232:Subset#1.ENUMERABLE.ANY([]).[],condition==($18,
$38),joinType=left), rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88368:Subset#3.LOGICAL.ANY([]).[], best=rel#88367,
importance=0.38129496402877694
rel#88369:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88236:Subset#3.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88367:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#88362:Subset#19.LOGICAL.ANY([]).[],right=rel#88364:Subset#1.LOGICAL.ANY([]).[],condition==($18,
$38),joinType=left), rowcount=1.0, cumulative cost={8.0 rows, 98.0 cpu, 0.0
io, 0.0 network}
rel#88492:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#88489:Subset#2.LOGICAL.ANY([]).[],condition==($8,
'RECEIVE')), rowcount=1.0, cumulative cost={8.0 rows, 98.0 cpu, 0.0 io, 0.0
network}
Set#4, type: RecordType(VARCHAR(65535) organization, VARCHAR(65535) message_id)
rel#88238:Subset#4.NONE.ANY([]).[], best=null, importance=0.6561
rel#88237:ProjectRel.NONE.ANY([]).[](child=rel#88236:Subset#3.NONE.ANY([]).[],organization=$29,message_id=$10),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88301:ProjectRel.NONE.ANY([]).[](child=rel#88300:Subset#18.NONE.ANY([]).[],organization=$2,message_id=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88274:ProjectRel.NONE.ANY([]).[](child=rel#88238:Subset#4.NONE.ANY([]).[],organization=$0,message_id=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88345:ProjectRel.NONE.ANY([]).[](child=rel#88343:Subset#22.NONE.ANY([]).[],organization=$3,message_id=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88355:ProjectRel.NONE.ANY([]).[](child=rel#88354:Subset#25.NONE.ANY([]).[],organization=$2,message_id=$0),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88313:Subset#4.LOGICAL.ANY([]).[], best=rel#88456,
importance=0.49499999999999994
rel#88314:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88238:Subset#4.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88401:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88399:Subset#25.LOGICAL.ANY([]).[],organization=$2,message_id=$0),
rowcount=1.0, cumulative cost={11.0 rows, 122.0 cpu, 0.0 io, 0.0 network}
rel#88402:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88357:Subset#22.LOGICAL.ANY([]).[],organization=$3,message_id=$1),
rowcount=1.0, cumulative cost={13.0 rows, 126.0 cpu, 0.0 io, 0.0 network}
rel#88446:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88360:Subset#18.LOGICAL.ANY([]).[],organization=$2,message_id=$1),
rowcount=1.0, cumulative cost={10.0 rows, 118.0 cpu, 0.0 io, 0.0 network}
rel#88454:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88313:Subset#4.LOGICAL.ANY([]).[],organization=$0,message_id=$1),
rowcount=1.0, cumulative cost={10.0 rows, 114.0 cpu, 0.0 io, 0.0 network}
rel#88456:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88368:Subset#3.LOGICAL.ANY([]).[],organization=$29,message_id=$10),
rowcount=1.0, cumulative cost={9.0 rows, 106.0 cpu, 0.0 io, 0.0 network}
Set#5, type: RecordType(VARCHAR(65535) organization, BIGINT $f1)
rel#88240:Subset#5.NONE.ANY([]).[], best=null,
importance=0.7290000000000001
rel#88239:AggregateRel.NONE.ANY([]).[](child=rel#88238:Subset#4.NONE.ANY([]).[],group={0},agg#0=COUNT(DISTINCT
$1)), rowcount=1.7976931348623158E307, cumulative cost={inf}
rel#88280:AggregateRel.NONE.ANY([]).[](child=rel#88279:Subset#14.NONE.ANY([]).[],group={0},agg#0=COUNT($1)),
rowcount=1.7976931348623158E307, cumulative cost={inf}
rel#88268:Subset#5.LOGICAL.ANY([]).[], best=rel#88283,
importance=0.38888888888888884
rel#88269:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88240:Subset#5.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88283:DrillAggregateRel.LOGICAL.ANY([]).[](child=rel#88281:Subset#14.LOGICAL.ANY([]).[],group={0},agg#0=COUNT($1)),
rowcount=1.0, cumulative cost={11.0 rows, 108.0 cpu, 0.0 io, 0.0 network}
Set#6, type: RecordType(CHAR(6) technology_type, VARCHAR(65535) organization,
INTEGER metric_no, CHAR(11) metric_name, BIGINT metric_value)
rel#88242:Subset#6.NONE.ANY([]).[], best=null, importance=0.81
rel#88241:ProjectRel.NONE.ANY([]).[](child=rel#88240:Subset#5.NONE.ANY([]).[],technology_type='emails',organization=$0,metric_no=1,metric_name='email_count',metric_value=*(2,
$1)), rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88260:Subset#6.LOGICAL.ANY([]).[], best=rel#88270, importance=0.405
rel#88261:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88242:Subset#6.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88270:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88268:Subset#5.LOGICAL.ANY([]).[],technology_type='emails',organization=$0,metric_no=1,metric_name='email_count',metric_value=*(2,
$1)), rowcount=1.0, cumulative cost={12.0 rows, 128.0 cpu, 0.0 io, 0.0 network}
Set#7, type: RecordType(VARCHAR(65535) userid, VARCHAR(65535) organization,
VARCHAR(65535) hierarchy, VARCHAR(65535) title, VARCHAR(65535) status,
VARCHAR(65535) country, VARCHAR(65535) workphone, VARCHAR(65535) mobilephone,
VARCHAR(65535) work_type, VARCHAR(65535) employee_type, VARCHAR(65535) emailid)
rel#88244:Subset#7.NONE.ANY([]).[], best=null,
importance=0.5904900000000001
rel#88243:FilterRel.NONE.ANY([]).[](child=rel#88232:Subset#1.ENUMERABLE.ANY([]).[],condition==($4,
'A')), rowcount=15.0, cumulative cost={inf}
rel#88442:Subset#7.LOGICAL.ANY([]).[], best=rel#88471,
importance=0.29524500000000004
rel#88443:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88244:Subset#7.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88471:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#88364:Subset#1.LOGICAL.ANY([]).[],condition==($4,
'A')), rowcount=1.0, cumulative cost={2.0 rows, 5.0 cpu, 0.0 io, 0.0 network}
Set#8, type: RecordType(VARCHAR(65535) organization)
rel#88246:Subset#8.NONE.ANY([]).[], best=null, importance=0.6561
rel#88245:ProjectRel.NONE.ANY([]).[](child=rel#88244:Subset#7.NONE.ANY([]).[],organization=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88293:ProjectRel.NONE.ANY([]).[](child=rel#88292:Subset#16.NONE.ANY([]).[],organization=$0),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88271:Subset#8.LOGICAL.ANY([]).[], best=rel#88455,
importance=0.32805
rel#88272:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88246:Subset#8.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88450:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88439:Subset#16.LOGICAL.ANY([]).[],organization=$0),
rowcount=1.0, cumulative cost={4.0 rows, 17.0 cpu, 0.0 io, 0.0 network}
rel#88455:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88442:Subset#7.LOGICAL.ANY([]).[],organization=$1),
rowcount=1.0, cumulative cost={3.0 rows, 9.0 cpu, 0.0 io, 0.0 network}
Set#9, type: RecordType(VARCHAR(65535) organization, BIGINT metric_value)
rel#88248:Subset#9.NONE.ANY([]).[], best=null,
importance=0.7290000000000001
rel#88247:AggregateRel.NONE.ANY([]).[](child=rel#88246:Subset#8.NONE.ANY([]).[],group={0},metric_value=COUNT()),
rowcount=1.7976931348623158E307, cumulative cost={inf}
rel#88265:Subset#9.LOGICAL.ANY([]).[], best=rel#88273,
importance=0.36450000000000005
rel#88266:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88248:Subset#9.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88273:DrillAggregateRel.LOGICAL.ANY([]).[](child=rel#88271:Subset#8.LOGICAL.ANY([]).[],group={0},metric_value=COUNT()),
rowcount=1.0, cumulative cost={4.0 rows, 10.0 cpu, 0.0 io, 0.0 network}
Set#10, type: RecordType(CHAR(6) technology_type, VARCHAR(65535) organization,
INTEGER metric_no, CHAR(27) metric_name, BIGINT metric_value)
rel#88250:Subset#10.NONE.ANY([]).[], best=null, importance=0.81
rel#88249:ProjectRel.NONE.ANY([]).[](child=rel#88248:Subset#9.NONE.ANY([]).[],technology_type='emails',organization=$0,metric_no=2,metric_name='email_active_employee_count',metric_value=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88262:Subset#10.LOGICAL.ANY([]).[], best=rel#88267, importance=0.405
rel#88263:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88250:Subset#10.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88267:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88265:Subset#9.LOGICAL.ANY([]).[],technology_type='emails',organization=$0,metric_no=2,metric_name='email_active_employee_count',metric_value=$1),
rowcount=1.0, cumulative cost={5.0 rows, 30.0 cpu, 0.0 io, 0.0 network}
Set#11, type: RecordType(CHAR(6) technology_type, VARCHAR(65535) organization,
INTEGER metric_no, CHAR(27) metric_name, BIGINT metric_value)
rel#88252:Subset#11.NONE.ANY([]).[], best=null, importance=0.9
rel#88251:UnionRel.NONE.ANY([]).[](input#0=rel#88242:Subset#6.NONE.ANY([]).[],input#1=rel#88250:Subset#10.NONE.ANY([]).[],all=true),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88253:ProjectRel.NONE.ANY([]).[](child=rel#88252:Subset#11.NONE.ANY([]).[],technology_type=$0,organization=$1,metric_no=$2,metric_name=$3,metric_value=$4),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88257:Subset#11.LOGICAL.ANY([]).[], best=null, importance=1.0
rel#88258:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88252:Subset#11.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88259:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88257:Subset#11.LOGICAL.ANY([]).[],technology_type=$0,organization=$1,metric_no=$2,metric_name=$3,metric_value=$4),
rowcount=1.7976931348623157E308, cumulative cost={inf}
Set#14, type: RecordType(VARCHAR(65535) organization, VARCHAR(65535) message_id)
rel#88279:Subset#14.NONE.ANY([]).[], best=null, importance=0.6561
rel#88278:AggregateRel.NONE.ANY([]).[](child=rel#88238:Subset#4.NONE.ANY([]).[],group={0,
1}), rowcount=1.7976931348623158E307, cumulative cost={inf}
rel#88281:Subset#14.LOGICAL.ANY([]).[], best=rel#88286,
importance=0.4431818181818181
rel#88282:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88279:Subset#14.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88286:DrillAggregateRel.LOGICAL.ANY([]).[](child=rel#88313:Subset#4.LOGICAL.ANY([]).[],group={0,
1}), rowcount=1.0, cumulative cost={10.0 rows, 107.0 cpu, 0.0 io, 0.0 network}
Set#15, type: RecordType(VARCHAR(65535) organization, VARCHAR(65535) status)
rel#88290:Subset#15.NONE.ANY([]).[], best=null, importance=0.531441
rel#88287:ProjectRel.NONE.ANY([]).[](child=rel#88232:Subset#1.ENUMERABLE.ANY([]).[],organization=$1,status=$4),
rowcount=100.0, cumulative cost={inf}
rel#88451:Subset#15.LOGICAL.ANY([]).[], best=rel#88470,
importance=0.2657205
rel#88452:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88290:Subset#15.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88470:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88364:Subset#1.LOGICAL.ANY([]).[],organization=$1,status=$4),
rowcount=1.0, cumulative cost={2.0 rows, 9.0 cpu, 0.0 io, 0.0 network}
Set#16, type: RecordType(VARCHAR(65535) organization, VARCHAR(65535) status)
rel#88292:Subset#16.NONE.ANY([]).[], best=null,
importance=0.5904900000000001
rel#88291:FilterRel.NONE.ANY([]).[](child=rel#88290:Subset#15.NONE.ANY([]).[],condition==($1,
'A')), rowcount=2.6965397022934733E307, cumulative cost={inf}
rel#88309:ProjectRel.NONE.ANY([]).[](child=rel#88244:Subset#7.NONE.ANY([]).[],organization=$1,status=$4),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88319:ProjectRel.NONE.ANY([]).[](child=rel#88292:Subset#16.NONE.ANY([]).[],organization=$0,status=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88439:Subset#16.LOGICAL.ANY([]).[], best=rel#88453,
importance=0.49499999999999994
rel#88440:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88292:Subset#16.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88441:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88439:Subset#16.LOGICAL.ANY([]).[],organization=$0,status=$1),
rowcount=1.0, cumulative cost={4.0 rows, 21.0 cpu, 0.0 io, 0.0 network}
rel#88444:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88442:Subset#7.LOGICAL.ANY([]).[],organization=$1,status=$4),
rowcount=1.0, cumulative cost={3.0 rows, 13.0 cpu, 0.0 io, 0.0 network}
rel#88453:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#88451:Subset#15.LOGICAL.ANY([]).[],condition==($1,
'A')), rowcount=1.0, cumulative cost={3.0 rows, 13.0 cpu, 0.0 io, 0.0 network}
Set#17, type: RecordType(VARCHAR(65535) event_id, VARCHAR(65535) message_id,
VARCHAR(65535) organization)
rel#88298:Subset#17.NONE.ANY([]).[], best=null, importance=0.531441
rel#88295:ProjectRel.NONE.ANY([]).[](child=rel#88234:Subset#2.NONE.ANY([]).[],event_id=$8,message_id=$10,organization=$29),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88463:ProjectRel.NONE.ANY([]).[](child=rel#88462:Subset#30.NONE.ANY([]).[],event_id=$0,message_id=$1,organization=$3),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88447:Subset#17.LOGICAL.ANY([]).[], best=rel#88491,
importance=0.4453781512605042
rel#88448:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88298:Subset#17.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88488:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88485:Subset#30.LOGICAL.ANY([]).[],event_id=$0,message_id=$1,organization=$3),
rowcount=3.0, cumulative cost={12.0 rows, 118.0 cpu, 0.0 io, 0.0 network}
rel#88491:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88489:Subset#2.LOGICAL.ANY([]).[],event_id=$8,message_id=$10,organization=$29),
rowcount=3.0, cumulative cost={8.0 rows, 98.0 cpu, 0.0 io, 0.0 network}
Set#18, type: RecordType(VARCHAR(65535) event_id, VARCHAR(65535) message_id,
VARCHAR(65535) organization)
rel#88300:Subset#18.NONE.ANY([]).[], best=null,
importance=0.5904900000000001
rel#88299:FilterRel.NONE.ANY([]).[](child=rel#88298:Subset#17.NONE.ANY([]).[],condition==($0,
'RECEIVE')), rowcount=2.6965397022934733E307, cumulative cost={inf}
rel#88304:ProjectRel.NONE.ANY([]).[](child=rel#88236:Subset#3.NONE.ANY([]).[],event_id=$8,message_id=$10,organization=$29),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88324:ProjectRel.NONE.ANY([]).[](child=rel#88300:Subset#18.NONE.ANY([]).[],event_id=$0,message_id=$1,organization=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88344:ProjectRel.NONE.ANY([]).[](child=rel#88343:Subset#22.NONE.ANY([]).[],event_id=$0,message_id=$1,organization=$3),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88360:Subset#18.LOGICAL.ANY([]).[], best=rel#88445,
importance=0.49499999999999994
rel#88361:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88300:Subset#18.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88359:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88357:Subset#22.LOGICAL.ANY([]).[],event_id=$0,message_id=$1,organization=$3),
rowcount=1.0, cumulative cost={13.0 rows, 130.0 cpu, 0.0 io, 0.0 network}
rel#88438:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88360:Subset#18.LOGICAL.ANY([]).[],event_id=$0,message_id=$1,organization=$2),
rowcount=1.0, cumulative cost={10.0 rows, 122.0 cpu, 0.0 io, 0.0 network}
rel#88445:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88368:Subset#3.LOGICAL.ANY([]).[],event_id=$8,message_id=$10,organization=$29),
rowcount=1.0, cumulative cost={9.0 rows, 110.0 cpu, 0.0 io, 0.0 network}
rel#88449:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#88447:Subset#17.LOGICAL.ANY([]).[],condition==($0,
'RECEIVE')), rowcount=1.0, cumulative cost={11.0 rows, 110.0 cpu, 0.0 io, 0.0
network}
Set#19, type: RecordType(VARCHAR(65535) date_time, VARCHAR(65535) client_ip,
VARCHAR(65535) client_hostname, VARCHAR(65535) server_ip, VARCHAR(65535)
server_hostname, VARCHAR(65535) source_context, VARCHAR(65535) connector_id,
VARCHAR(65535) source, VARCHAR(65535) event_id, VARCHAR(65535)
internal_message_id, VARCHAR(65535) message_id, VARCHAR(65535)
recipient_address, VARCHAR(65535) recipient_status, INTEGER total_bytes,
INTEGER recipient_count, VARCHAR(65535) related_recipient_address,
VARCHAR(65535) reference, VARCHAR(65535) message_subject, VARCHAR(65535)
sender_address, VARCHAR(65535) return_path, VARCHAR(65535) message_info,
VARCHAR(65535) directionality, VARCHAR(65535) tenant_id, VARCHAR(65535)
original_client_ip, VARCHAR(65535) original_server_ip, VARCHAR(65535)
custom_data, VARCHAR(65535) emailfilename, TIMESTAMP(0) load_dt)
rel#88334:Subset#19.NONE.ANY([]).[], best=null, importance=0.531441
rel#88332:FilterRel.NONE.ANY([]).[](child=rel#88231:Subset#0.ENUMERABLE.ANY([]).[],condition==($8,
'RECEIVE')), rowcount=15.0, cumulative cost={inf}
rel#88362:Subset#19.LOGICAL.ANY([]).[], best=rel#88420,
importance=0.43589743589743585
rel#88363:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88334:Subset#19.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88420:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#88409:Subset#0.LOGICAL.ANY([]).[],condition==($8,
'RECEIVE')), rowcount=1.0, cumulative cost={6.0 rows, 96.0 cpu, 0.0 io, 0.0
network}
Set#20, type: RecordType(VARCHAR(65535) event_id, VARCHAR(65535) message_id,
VARCHAR(65535) sender_address)
rel#88340:Subset#20.NONE.ANY([]).[], best=null,
importance=0.4782969000000001
rel#88336:ProjectRel.NONE.ANY([]).[](child=rel#88334:Subset#19.NONE.ANY([]).[],event_id=$8,message_id=$10,sender_address=$18),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88376:ProjectRel.NONE.ANY([]).[](child=rel#88340:Subset#20.NONE.ANY([]).[],event_id=$0,message_id=$1,sender_address=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88374:FilterRel.NONE.ANY([]).[](child=rel#88373:Subset#26.NONE.ANY([]).[],condition==($0,
'RECEIVE')), rowcount=2.6965397022934733E307, cumulative cost={inf}
rel#88393:Subset#20.LOGICAL.ANY([]).[], best=rel#88398,
importance=0.49499999999999994
rel#88394:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88340:Subset#20.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88395:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88393:Subset#20.LOGICAL.ANY([]).[],event_id=$0,message_id=$1,sender_address=$2),
rowcount=1.0, cumulative cost={10.0 rows, 120.0 cpu, 0.0 io, 0.0 network}
rel#88398:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#88396:Subset#26.LOGICAL.ANY([]).[],condition==($0,
'RECEIVE')), rowcount=1.0, cumulative cost={9.0 rows, 108.0 cpu, 0.0 io, 0.0
network}
rel#88419:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88362:Subset#19.LOGICAL.ANY([]).[],event_id=$8,message_id=$10,sender_address=$18),
rowcount=1.0, cumulative cost={7.0 rows, 108.0 cpu, 0.0 io, 0.0 network}
Set#21, type: RecordType(VARCHAR(65535) organization, VARCHAR(65535) emailid)
rel#88341:Subset#21.NONE.ANY([]).[], best=null,
importance=0.4304672100000001
rel#88337:ProjectRel.NONE.ANY([]).[](child=rel#88232:Subset#1.ENUMERABLE.ANY([]).[],organization=$1,emailid=$10),
rowcount=100.0, cumulative cost={inf}
rel#88348:ProjectRel.NONE.ANY([]).[](child=rel#88341:Subset#21.NONE.ANY([]).[],organization=$0,emailid=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88405:Subset#21.LOGICAL.ANY([]).[], best=rel#88437,
importance=0.49499999999999994
rel#88406:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88341:Subset#21.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88435:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88405:Subset#21.LOGICAL.ANY([]).[],organization=$0,emailid=$1),
rowcount=1.0, cumulative cost={3.0 rows, 17.0 cpu, 0.0 io, 0.0 network}
rel#88437:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88364:Subset#1.LOGICAL.ANY([]).[],organization=$1,emailid=$10),
rowcount=1.0, cumulative cost={2.0 rows, 9.0 cpu, 0.0 io, 0.0 network}
Set#22, type: RecordType(VARCHAR(65535) event_id, VARCHAR(65535) message_id,
VARCHAR(65535) sender_address, VARCHAR(65535) organization, VARCHAR(65535)
emailid)
rel#88343:Subset#22.NONE.ANY([]).[], best=null, importance=0.531441
rel#88342:JoinRel.NONE.ANY([]).[](left=rel#88340:Subset#20.NONE.ANY([]).[],right=rel#88341:Subset#21.NONE.ANY([]).[],condition==($2,
$4),joinType=left), rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88464:FilterRel.NONE.ANY([]).[](child=rel#88462:Subset#30.NONE.ANY([]).[],condition==($0,
'RECEIVE')), rowcount=2.6965397022934733E307, cumulative cost={inf}
rel#88357:Subset#22.LOGICAL.ANY([]).[], best=rel#88418,
importance=0.2657205
rel#88358:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88343:Subset#22.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88418:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#88393:Subset#20.LOGICAL.ANY([]).[],right=rel#88405:Subset#21.LOGICAL.ANY([]).[],condition==($2,
$4),joinType=left), rowcount=1.0, cumulative cost={12.0 rows, 118.0 cpu, 0.0
io, 0.0 network}
rel#88487:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#88485:Subset#30.LOGICAL.ANY([]).[],condition==($0,
'RECEIVE')), rowcount=1.0, cumulative cost={12.0 rows, 118.0 cpu, 0.0 io, 0.0
network}
Set#23, type: RecordType(VARCHAR(65535) message_id, VARCHAR(65535)
sender_address)
rel#88351:Subset#23.NONE.ANY([]).[], best=null, importance=0.531441
rel#88347:ProjectRel.NONE.ANY([]).[](child=rel#88340:Subset#20.NONE.ANY([]).[],message_id=$1,sender_address=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88378:ProjectRel.NONE.ANY([]).[](child=rel#88334:Subset#19.NONE.ANY([]).[],message_id=$10,sender_address=$18),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88413:Subset#23.LOGICAL.ANY([]).[], best=rel#88434,
importance=0.3992805755395683
rel#88414:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88351:Subset#23.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88434:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88362:Subset#19.LOGICAL.ANY([]).[],message_id=$10,sender_address=$18),
rowcount=1.0, cumulative cost={7.0 rows, 104.0 cpu, 0.0 io, 0.0 network}
rel#88436:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88393:Subset#20.LOGICAL.ANY([]).[],message_id=$1,sender_address=$2),
rowcount=1.0, cumulative cost={10.0 rows, 116.0 cpu, 0.0 io, 0.0 network}
Set#25, type: RecordType(VARCHAR(65535) message_id, VARCHAR(65535)
sender_address, VARCHAR(65535) organization, VARCHAR(65535) emailid)
rel#88354:Subset#25.NONE.ANY([]).[], best=null,
importance=0.5904900000000001
rel#88383:JoinRel.NONE.ANY([]).[](left=rel#88351:Subset#23.NONE.ANY([]).[],right=rel#88341:Subset#21.NONE.ANY([]).[],condition==($1,
$3),joinType=left), rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88399:Subset#25.LOGICAL.ANY([]).[], best=rel#88407,
importance=0.49499999999999994
rel#88400:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88354:Subset#25.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88407:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#88413:Subset#23.LOGICAL.ANY([]).[],right=rel#88405:Subset#21.LOGICAL.ANY([]).[],condition==($1,
$3),joinType=left), rowcount=1.0, cumulative cost={10.0 rows, 114.0 cpu, 0.0
io, 0.0 network}
Set#26, type: RecordType(VARCHAR(65535) event_id, VARCHAR(65535) message_id,
VARCHAR(65535) sender_address)
rel#88373:Subset#26.NONE.ANY([]).[], best=null,
importance=0.4304672100000001
rel#88370:ProjectRel.NONE.ANY([]).[](child=rel#88231:Subset#0.ENUMERABLE.ANY([]).[],event_id=$8,message_id=$10,sender_address=$18),
rowcount=100.0, cumulative cost={inf}
rel#88396:Subset#26.LOGICAL.ANY([]).[], best=rel#88412,
importance=0.21523360500000005
rel#88397:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88373:Subset#26.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88412:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#88409:Subset#0.LOGICAL.ANY([]).[],event_id=$8,message_id=$10,sender_address=$18),
rowcount=3.0, cumulative cost={6.0 rows, 96.0 cpu, 0.0 io, 0.0 network}
Set#30, type: RecordType(VARCHAR(65535) event_id, VARCHAR(65535) message_id,
VARCHAR(65535) sender_address, VARCHAR(65535) organization, VARCHAR(65535)
emailid)
rel#88462:Subset#30.NONE.ANY([]).[], best=null,
importance=0.4782969000000001
rel#88461:JoinRel.NONE.ANY([]).[](left=rel#88373:Subset#26.NONE.ANY([]).[],right=rel#88341:Subset#21.NONE.ANY([]).[],condition==($2,
$4),joinType=left), rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88485:Subset#30.LOGICAL.ANY([]).[], best=rel#88506,
importance=0.44230769230769224
rel#88486:AbstractConverter.LOGICAL.ANY([]).[](child=rel#88462:Subset#30.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
rel#88506:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#88396:Subset#26.LOGICAL.ANY([]).[],right=rel#88405:Subset#21.LOGICAL.ANY([]).[],condition==($2,
$4),joinType=left), rowcount=3.0, cumulative cost={9.0 rows, 106.0 cpu, 0.0
io, 0.0 network}
]"
]
{code}
> Cannot plan exception- Union all
> --------------------------------
>
> Key: DRILL-1101
> URL: https://issues.apache.org/jira/browse/DRILL-1101
> Project: Apache Drill
> Issue Type: Bug
> Components: Query Planning & Optimization
> Reporter: Ramana Inukonda Nagaraj
> Priority: Blocker
>
> Following query results in a CannotPlanException
> select emails.technology_type , emails.organization,
> emails.metric_no, emails.metric_name, emails.metric_value
> from(
> select 'emails' as technology_type ,
> b1.organization as organization,
> 1 as metric_no, 'email_count' as metric_name, 2*count(distinct
> message_id) as metric_value
> from emails a1
> left outer join employee_table b1
> on (a1.sender_address = b1.emailid)
> where a1.event_id = 'RECEIVE'
> group by b1.organization
> union all
> select 'emails' as technology_type,
> b2.organization as organization,
> 2 as metric_no, 'email_active_employee_count' as metric_name,
> count(*) as metric_value
> from employee_table b2
> where b2.status = 'A'
> group by b2.organization
> ) emails;
--
This message was sent by Atlassian JIRA
(v6.2#6252)
