drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ramana Inukonda Nagaraj (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (DRILL-1101) Cannot plan exception- Union all
Date Thu, 03 Jul 2014 00:42:25 GMT

    [ 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)

Mime
View raw message