ChenShuai1981 opened a new issue #6445: IN clause too many values?
URL: https://github.com/apache/incubator-druid/issues/6445
 
 
   Environment:
   RHCE/HDP 2.6.1 with Druid 0.10.0 installed
   
   SQL:
   
   > SELECT  "count", externalCount ,successSum , 
externalSuccessSum,consumeTimeSum ,externalConsumeTimeSum, dataSourceId,__time 
AS dateTime  
   > FROM "dev-datasource-execution-record" WHERE __time >=  
MILLIS_TO_TIMESTAMP(1529337600000) AND __time <= 
MILLIS_TO_TIMESTAMP(1529510399999) 
   > AND dataSourceId in 
(35,50,81,102,103,104,105,106,107,122,131,155,156,163,164,165,166,167,168,170)
   
   **But when I remove "170" (the last one value in IN clause), it works fine, 
why? Does values in IN clause have max size limitation?**
   
   Error:
   
   > SQL Error [00000]: Error -1 (00000) : Error while executing SQL "SELECT  
"count", externalCount ,successSum , externalSuccessSum,consumeTimeSum 
,externalConsumeTimeSum, dataSourceId,__time AS dateTime  
   > FROM "dev-datasource-execution-record" WHERE __time >=  
MILLIS_TO_TIMESTAMP(1529337600000) AND __time <= 
MILLIS_TO_TIMESTAMP(1529510399999) 
   > AND dataSourceId in 
(35,50,81,102,103,104,105,106,107,122,131,155,156,163,164,165,166,167,168,170)":
 Remote driver error: CannotPlanException: Node [rel#515482:Subset#5.DRUID.[]] 
could not be implemented; planner state:
   > 
   > Root: rel#515482:Subset#5.DRUID.[]
   > Original rel:
   > 
   > Sets:
   > Set#0, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515472:Subset#0.NONE.[], best=null, importance=0.6561
   >            rel#515466:LogicalTableScan.NONE.[](table=[druid, 
dev-datasource-execution-record]), rowcount=100.0, cumulative cost={inf}
   >            
rel#515633:DruidQueryRel.NONE.[](dataSource=dev-datasource-execution-record), 
rowcount=1.0, cumulative cost={inf}
   >    rel#515645:Subset#0.DRUID.[], best=rel#515644, importance=0.32805
   >            
rel#515644:DruidQueryRel.DRUID.[](dataSource=dev-datasource-execution-record), 
rowcount=1.0, cumulative cost={1.0 rows, 0.0 cpu, 0.0 io}
   > Set#1, type: RecordType(VARCHAR ROW_VALUE)
   >    rel#515473:Subset#1.NONE.[0], best=null, importance=0.5904900000000001
   >            rel#515467:LogicalValues.NONE.[[0]](type=RecordType(VARCHAR 
ROW_VALUE),tuples=[{ 35 }, { 50 }, { 81 }, { 102 }, { 103 }, { 104 }, { 105 }, 
{ 106 }, { 107 }, { 122 }, { 131 }, { 155 }, { 156 }, { 163 }, { 164 }, { 165 
}, { 166 }, { 167 }, { 168 }, { 170 }]), rowcount=20.0, cumulative cost={inf}
   >    rel#515632:Subset#1.NONE.[], best=null, importance=0.6561
   >            rel#515467:LogicalValues.NONE.[[0]](type=RecordType(VARCHAR 
ROW_VALUE),tuples=[{ 35 }, { 50 }, { 81 }, { 102 }, { 103 }, { 104 }, { 105 }, 
{ 106 }, { 107 }, { 122 }, { 131 }, { 155 }, { 156 }, { 163 }, { 164 }, { 165 
}, { 166 }, { 167 }, { 168 }, { 170 }]), rowcount=20.0, cumulative cost={inf}
   >            
rel#515474:LogicalAggregate.NONE.[](input=rel#515473:Subset#1.NONE.[0],group={0}),
 rowcount=20.0, cumulative cost={inf}
   > Set#3, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum, VARCHAR ROW_VALUE)
   >    rel#515477:Subset#3.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515476:LogicalJoin.NONE.[](left=rel#515472:Subset#0.NONE.[],right=rel#515632:Subset#1.NONE.[],condition==($3,
 $8),joinType=inner), rowcount=300.0, cumulative cost={inf}
   >            
rel#515514:LogicalProject.NONE.[](input=rel#515513:Subset#9.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8,ROW_VALUE=$0),
 rowcount=300.0, cumulative cost={inf}
   > Set#4, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum, VARCHAR ROW_VALUE)
   >    rel#515479:Subset#4.NONE.[], best=null, importance=0.81
   >            
rel#515478:LogicalFilter.NONE.[](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 MILLIS_TO_TIMESTAMP(1529337600000)), <=($0, 
MILLIS_TO_TIMESTAMP(1529510399999)), true)), importance=0.0, rowcount=75.0, 
cumulative cost={inf}
   >            
rel#515492:LogicalFilter.NONE.[[]](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515531:LogicalJoin.NONE.[](left=rel#515530:Subset#12.NONE.[],right=rel#515632:Subset#1.NONE.[],condition==($3,
 $8),joinType=inner), rowcount=75.0, cumulative cost={inf}
   >            
rel#515555:LogicalFilter.NONE.[](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515600:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8,ROW_VALUE=$0),
 rowcount=75.0, cumulative cost={inf}
   > Set#5, type: RecordType(BIGINT count, BIGINT externalCount, BIGINT 
successSum, BIGINT externalSuccessSum, DOUBLE consumeTimeSum, DOUBLE 
externalConsumeTimeSum, VARCHAR dataSourceId, TIMESTAMP(0) dateTime)
   >    rel#515481:Subset#5.NONE.[], best=null, importance=0.9
   >            
rel#515480:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],count=$2,externalCount=$5,successSum=$7,externalSuccessSum=$6,consumeTimeSum=$1,externalConsumeTimeSum=$4,dataSourceId=$3,dateTime=$0),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515490:LogicalProject.NONE.[](input=rel#515489:Subset#7.NONE.[],count=$2,externalCount=$5,successSum=$7,externalSuccessSum=$6,consumeTimeSum=$1,externalConsumeTimeSum=$4,dataSourceId=$3,dateTime=$0),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515523:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],count=$3,externalCount=$6,successSum=$8,externalSuccessSum=$7,consumeTimeSum=$2,externalConsumeTimeSum=$5,dataSourceId=$4,dateTime=$1),
 rowcount=75.0, cumulative cost={inf}
   >    rel#515482:Subset#5.DRUID.[], best=null, importance=1.0
   >            
rel#515483:AbstractConverter.DRUID.[](input=rel#515481:Subset#5.NONE.[],convention=DRUID,sort=[]),
 rowcount=75.0, cumulative cost={inf}
   > Set#6, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515487:Subset#6.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515484:LogicalProject.NONE.[](input=rel#515477:Subset#3.NONE.[],__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=300.0, cumulative cost={inf}
   >            
rel#515518:LogicalProject.NONE.[](input=rel#515513:Subset#9.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8),
 rowcount=300.0, cumulative cost={inf}
   > Set#7, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515489:Subset#7.NONE.[], best=null, importance=0.81
   >            
rel#515488:LogicalFilter.NONE.[](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 MILLIS_TO_TIMESTAMP(1529337600000)), <=($0, 
MILLIS_TO_TIMESTAMP(1529510399999)))), importance=0.0, rowcount=75.0, 
cumulative cost={inf}
   >            
rel#515491:LogicalFilter.NONE.[[]](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515495:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515500:LogicalFilter.NONE.[](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515522:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8),
 rowcount=75.0, cumulative cost={inf}
   > Set#9, type: RecordType(VARCHAR ROW_VALUE, TIMESTAMP(0) __time, DOUBLE 
consumeTimeSum, BIGINT count, VARCHAR dataSourceId, DOUBLE 
externalConsumeTimeSum, BIGINT externalCount, BIGINT externalSuccessSum, BIGINT 
successSum)
   >    rel#515513:Subset#9.NONE.[], best=null, importance=0.6561
   >            
rel#515511:LogicalJoin.NONE.[](left=rel#515632:Subset#1.NONE.[],right=rel#515472:Subset#0.NONE.[],condition==($4,
 $0),joinType=inner), rowcount=300.0, cumulative cost={inf}
   >            
rel#515517:LogicalProject.NONE.[](input=rel#515477:Subset#3.NONE.[],ROW_VALUE=$8,__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=300.0, cumulative cost={inf}
   > Set#10, type: RecordType(VARCHAR ROW_VALUE, TIMESTAMP(0) __time, DOUBLE 
consumeTimeSum, BIGINT count, VARCHAR dataSourceId, DOUBLE 
externalConsumeTimeSum, BIGINT externalCount, BIGINT externalSuccessSum, BIGINT 
successSum)
   >    rel#515521:Subset#10.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515519:LogicalFilter.NONE.[](input=rel#515513:Subset#9.NONE.[],condition=AND(>=($1,
 2018-06-18 16:00:00), <=($1, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515524:LogicalFilter.NONE.[[]](input=rel#515513:Subset#9.NONE.[],condition=AND(>=($1,
 2018-06-18 16:00:00), <=($1, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515537:LogicalJoin.NONE.[](left=rel#515632:Subset#1.NONE.[],right=rel#515530:Subset#12.NONE.[],condition==($4,
 $0),joinType=inner), rowcount=75.0, cumulative cost={inf}
   >            
rel#515543:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],ROW_VALUE=$8,__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=75.0, cumulative cost={inf}
   > Set#12, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, 
BIGINT count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515530:Subset#12.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515528:LogicalFilter.NONE.[[]](input=rel#515472:Subset#0.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=25.0, cumulative 
cost={inf}
   >            
rel#515634:DruidQueryRel.NONE.[](dataSource=dev-datasource-execution-record,intervals=[2018-06-18T16:00:00.000Z/2018-06-20T16:00:00.001Z]),
 rowcount=1.0, cumulative cost={inf}
   >    rel#515643:Subset#12.DRUID.[], best=rel#515642, 
importance=0.36450000000000005
   >            
rel#515642:DruidQueryRel.DRUID.[](dataSource=dev-datasource-execution-record,intervals=[2018-06-18T16:00:00.000Z/2018-06-20T16:00:00.001Z]),
 rowcount=1.0, cumulative cost={0.1 rows, 0.0 cpu, 0.0 io}
   > 
   > 
   >   Error -1 (00000) : Error while executing SQL "SELECT  "count", 
externalCount ,successSum , externalSuccessSum,consumeTimeSum 
,externalConsumeTimeSum, dataSourceId,__time AS dateTime  
   > FROM "dev-datasource-execution-record" WHERE __time >=  
MILLIS_TO_TIMESTAMP(1529337600000) AND __time <= 
MILLIS_TO_TIMESTAMP(1529510399999) 
   > AND dataSourceId in 
(35,50,81,102,103,104,105,106,107,122,131,155,156,163,164,165,166,167,168,170)":
 Remote driver error: CannotPlanException: Node [rel#515482:Subset#5.DRUID.[]] 
could not be implemented; planner state:
   > 
   > Root: rel#515482:Subset#5.DRUID.[]
   > Original rel:
   > 
   > Sets:
   > Set#0, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515472:Subset#0.NONE.[], best=null, importance=0.6561
   >            rel#515466:LogicalTableScan.NONE.[](table=[druid, 
dev-datasource-execution-record]), rowcount=100.0, cumulative cost={inf}
   >            
rel#515633:DruidQueryRel.NONE.[](dataSource=dev-datasource-execution-record), 
rowcount=1.0, cumulative cost={inf}
   >    rel#515645:Subset#0.DRUID.[], best=rel#515644, importance=0.32805
   >            
rel#515644:DruidQueryRel.DRUID.[](dataSource=dev-datasource-execution-record), 
rowcount=1.0, cumulative cost={1.0 rows, 0.0 cpu, 0.0 io}
   > Set#1, type: RecordType(VARCHAR ROW_VALUE)
   >    rel#515473:Subset#1.NONE.[0], best=null, importance=0.5904900000000001
   >            rel#515467:LogicalValues.NONE.[[0]](type=RecordType(VARCHAR 
ROW_VALUE),tuples=[{ 35 }, { 50 }, { 81 }, { 102 }, { 103 }, { 104 }, { 105 }, 
{ 106 }, { 107 }, { 122 }, { 131 }, { 155 }, { 156 }, { 163 }, { 164 }, { 165 
}, { 166 }, { 167 }, { 168 }, { 170 }]), rowcount=20.0, cumulative cost={inf}
   >    rel#515632:Subset#1.NONE.[], best=null, importance=0.6561
   >            rel#515467:LogicalValues.NONE.[[0]](type=RecordType(VARCHAR 
ROW_VALUE),tuples=[{ 35 }, { 50 }, { 81 }, { 102 }, { 103 }, { 104 }, { 105 }, 
{ 106 }, { 107 }, { 122 }, { 131 }, { 155 }, { 156 }, { 163 }, { 164 }, { 165 
}, { 166 }, { 167 }, { 168 }, { 170 }]), rowcount=20.0, cumulative cost={inf}
   >            
rel#515474:LogicalAggregate.NONE.[](input=rel#515473:Subset#1.NONE.[0],group={0}),
 rowcount=20.0, cumulative cost={inf}
   > Set#3, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum, VARCHAR ROW_VALUE)
   >    rel#515477:Subset#3.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515476:LogicalJoin.NONE.[](left=rel#515472:Subset#0.NONE.[],right=rel#515632:Subset#1.NONE.[],condition==($3,
 $8),joinType=inner), rowcount=300.0, cumulative cost={inf}
   >            
rel#515514:LogicalProject.NONE.[](input=rel#515513:Subset#9.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8,ROW_VALUE=$0),
 rowcount=300.0, cumulative cost={inf}
   > Set#4, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum, VARCHAR ROW_VALUE)
   >    rel#515479:Subset#4.NONE.[], best=null, importance=0.81
   >            
rel#515478:LogicalFilter.NONE.[](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 MILLIS_TO_TIMESTAMP(1529337600000)), <=($0, 
MILLIS_TO_TIMESTAMP(1529510399999)), true)), importance=0.0, rowcount=75.0, 
cumulative cost={inf}
   >            
rel#515492:LogicalFilter.NONE.[[]](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515531:LogicalJoin.NONE.[](left=rel#515530:Subset#12.NONE.[],right=rel#515632:Subset#1.NONE.[],condition==($3,
 $8),joinType=inner), rowcount=75.0, cumulative cost={inf}
   >            
rel#515555:LogicalFilter.NONE.[](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515600:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8,ROW_VALUE=$0),
 rowcount=75.0, cumulative cost={inf}
   > Set#5, type: RecordType(BIGINT count, BIGINT externalCount, BIGINT 
successSum, BIGINT externalSuccessSum, DOUBLE consumeTimeSum, DOUBLE 
externalConsumeTimeSum, VARCHAR dataSourceId, TIMESTAMP(0) dateTime)
   >    rel#515481:Subset#5.NONE.[], best=null, importance=0.9
   >            
rel#515480:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],count=$2,externalCount=$5,successSum=$7,externalSuccessSum=$6,consumeTimeSum=$1,externalConsumeTimeSum=$4,dataSourceId=$3,dateTime=$0),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515490:LogicalProject.NONE.[](input=rel#515489:Subset#7.NONE.[],count=$2,externalCount=$5,successSum=$7,externalSuccessSum=$6,consumeTimeSum=$1,externalConsumeTimeSum=$4,dataSourceId=$3,dateTime=$0),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515523:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],count=$3,externalCount=$6,successSum=$8,externalSuccessSum=$7,consumeTimeSum=$2,externalConsumeTimeSum=$5,dataSourceId=$4,dateTime=$1),
 rowcount=75.0, cumulative cost={inf}
   >    rel#515482:Subset#5.DRUID.[], best=null, importance=1.0
   >            
rel#515483:AbstractConverter.DRUID.[](input=rel#515481:Subset#5.NONE.[],convention=DRUID,sort=[]),
 rowcount=75.0, cumulative cost={inf}
   > Set#6, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515487:Subset#6.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515484:LogicalProject.NONE.[](input=rel#515477:Subset#3.NONE.[],__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=300.0, cumulative cost={inf}
   >            
rel#515518:LogicalProject.NONE.[](input=rel#515513:Subset#9.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8),
 rowcount=300.0, cumulative cost={inf}
   > Set#7, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515489:Subset#7.NONE.[], best=null, importance=0.81
   >            
rel#515488:LogicalFilter.NONE.[](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 MILLIS_TO_TIMESTAMP(1529337600000)), <=($0, 
MILLIS_TO_TIMESTAMP(1529510399999)))), importance=0.0, rowcount=75.0, 
cumulative cost={inf}
   >            
rel#515491:LogicalFilter.NONE.[[]](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515495:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515500:LogicalFilter.NONE.[](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515522:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8),
 rowcount=75.0, cumulative cost={inf}
   > Set#9, type: RecordType(VARCHAR ROW_VALUE, TIMESTAMP(0) __time, DOUBLE 
consumeTimeSum, BIGINT count, VARCHAR dataSourceId, DOUBLE 
externalConsumeTimeSum, BIGINT externalCount, BIGINT externalSuccessSum, BIGINT 
successSum)
   >    rel#515513:Subset#9.NONE.[], best=null, importance=0.6561
   >            
rel#515511:LogicalJoin.NONE.[](left=rel#515632:Subset#1.NONE.[],right=rel#515472:Subset#0.NONE.[],condition==($4,
 $0),joinType=inner), rowcount=300.0, cumulative cost={inf}
   >            
rel#515517:LogicalProject.NONE.[](input=rel#515477:Subset#3.NONE.[],ROW_VALUE=$8,__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=300.0, cumulative cost={inf}
   > Set#10, type: RecordType(VARCHAR ROW_VALUE, TIMESTAMP(0) __time, DOUBLE 
consumeTimeSum, BIGINT count, VARCHAR dataSourceId, DOUBLE 
externalConsumeTimeSum, BIGINT externalCount, BIGINT externalSuccessSum, BIGINT 
successSum)
   >    rel#515521:Subset#10.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515519:LogicalFilter.NONE.[](input=rel#515513:Subset#9.NONE.[],condition=AND(>=($1,
 2018-06-18 16:00:00), <=($1, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515524:LogicalFilter.NONE.[[]](input=rel#515513:Subset#9.NONE.[],condition=AND(>=($1,
 2018-06-18 16:00:00), <=($1, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515537:LogicalJoin.NONE.[](left=rel#515632:Subset#1.NONE.[],right=rel#515530:Subset#12.NONE.[],condition==($4,
 $0),joinType=inner), rowcount=75.0, cumulative cost={inf}
   >            
rel#515543:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],ROW_VALUE=$8,__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=75.0, cumulative cost={inf}
   > Set#12, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, 
BIGINT count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515530:Subset#12.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515528:LogicalFilter.NONE.[[]](input=rel#515472:Subset#0.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=25.0, cumulative 
cost={inf}
   >            
rel#515634:DruidQueryRel.NONE.[](dataSource=dev-datasource-execution-record,intervals=[2018-06-18T16:00:00.000Z/2018-06-20T16:00:00.001Z]),
 rowcount=1.0, cumulative cost={inf}
   >    rel#515643:Subset#12.DRUID.[], best=rel#515642, 
importance=0.36450000000000005
   >            
rel#515642:DruidQueryRel.DRUID.[](dataSource=dev-datasource-execution-record,intervals=[2018-06-18T16:00:00.000Z/2018-06-20T16:00:00.001Z]),
 rowcount=1.0, cumulative cost={0.1 rows, 0.0 cpu, 0.0 io}
   > 
   > 
   >   Error -1 (00000) : Error while executing SQL "SELECT  "count", 
externalCount ,successSum , externalSuccessSum,consumeTimeSum 
,externalConsumeTimeSum, dataSourceId,__time AS dateTime  
   > FROM "dev-datasource-execution-record" WHERE __time >=  
MILLIS_TO_TIMESTAMP(1529337600000) AND __time <= 
MILLIS_TO_TIMESTAMP(1529510399999) 
   > AND dataSourceId in 
(35,50,81,102,103,104,105,106,107,122,131,155,156,163,164,165,166,167,168,170)":
 Remote driver error: CannotPlanException: Node [rel#515482:Subset#5.DRUID.[]] 
could not be implemented; planner state:
   > 
   > Root: rel#515482:Subset#5.DRUID.[]
   > Original rel:
   > 
   > Sets:
   > Set#0, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515472:Subset#0.NONE.[], best=null, importance=0.6561
   >            rel#515466:LogicalTableScan.NONE.[](table=[druid, 
dev-datasource-execution-record]), rowcount=100.0, cumulative cost={inf}
   >            
rel#515633:DruidQueryRel.NONE.[](dataSource=dev-datasource-execution-record), 
rowcount=1.0, cumulative cost={inf}
   >    rel#515645:Subset#0.DRUID.[], best=rel#515644, importance=0.32805
   >            
rel#515644:DruidQueryRel.DRUID.[](dataSource=dev-datasource-execution-record), 
rowcount=1.0, cumulative cost={1.0 rows, 0.0 cpu, 0.0 io}
   > Set#1, type: RecordType(VARCHAR ROW_VALUE)
   >    rel#515473:Subset#1.NONE.[0], best=null, importance=0.5904900000000001
   >            rel#515467:LogicalValues.NONE.[[0]](type=RecordType(VARCHAR 
ROW_VALUE),tuples=[{ 35 }, { 50 }, { 81 }, { 102 }, { 103 }, { 104 }, { 105 }, 
{ 106 }, { 107 }, { 122 }, { 131 }, { 155 }, { 156 }, { 163 }, { 164 }, { 165 
}, { 166 }, { 167 }, { 168 }, { 170 }]), rowcount=20.0, cumulative cost={inf}
   >    rel#515632:Subset#1.NONE.[], best=null, importance=0.6561
   >            rel#515467:LogicalValues.NONE.[[0]](type=RecordType(VARCHAR 
ROW_VALUE),tuples=[{ 35 }, { 50 }, { 81 }, { 102 }, { 103 }, { 104 }, { 105 }, 
{ 106 }, { 107 }, { 122 }, { 131 }, { 155 }, { 156 }, { 163 }, { 164 }, { 165 
}, { 166 }, { 167 }, { 168 }, { 170 }]), rowcount=20.0, cumulative cost={inf}
   >            
rel#515474:LogicalAggregate.NONE.[](input=rel#515473:Subset#1.NONE.[0],group={0}),
 rowcount=20.0, cumulative cost={inf}
   > Set#3, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum, VARCHAR ROW_VALUE)
   >    rel#515477:Subset#3.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515476:LogicalJoin.NONE.[](left=rel#515472:Subset#0.NONE.[],right=rel#515632:Subset#1.NONE.[],condition==($3,
 $8),joinType=inner), rowcount=300.0, cumulative cost={inf}
   >            
rel#515514:LogicalProject.NONE.[](input=rel#515513:Subset#9.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8,ROW_VALUE=$0),
 rowcount=300.0, cumulative cost={inf}
   > Set#4, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum, VARCHAR ROW_VALUE)
   >    rel#515479:Subset#4.NONE.[], best=null, importance=0.81
   >            
rel#515478:LogicalFilter.NONE.[](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 MILLIS_TO_TIMESTAMP(1529337600000)), <=($0, 
MILLIS_TO_TIMESTAMP(1529510399999)), true)), importance=0.0, rowcount=75.0, 
cumulative cost={inf}
   >            
rel#515492:LogicalFilter.NONE.[[]](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515531:LogicalJoin.NONE.[](left=rel#515530:Subset#12.NONE.[],right=rel#515632:Subset#1.NONE.[],condition==($3,
 $8),joinType=inner), rowcount=75.0, cumulative cost={inf}
   >            
rel#515555:LogicalFilter.NONE.[](input=rel#515477:Subset#3.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515600:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8,ROW_VALUE=$0),
 rowcount=75.0, cumulative cost={inf}
   > Set#5, type: RecordType(BIGINT count, BIGINT externalCount, BIGINT 
successSum, BIGINT externalSuccessSum, DOUBLE consumeTimeSum, DOUBLE 
externalConsumeTimeSum, VARCHAR dataSourceId, TIMESTAMP(0) dateTime)
   >    rel#515481:Subset#5.NONE.[], best=null, importance=0.9
   >            
rel#515480:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],count=$2,externalCount=$5,successSum=$7,externalSuccessSum=$6,consumeTimeSum=$1,externalConsumeTimeSum=$4,dataSourceId=$3,dateTime=$0),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515490:LogicalProject.NONE.[](input=rel#515489:Subset#7.NONE.[],count=$2,externalCount=$5,successSum=$7,externalSuccessSum=$6,consumeTimeSum=$1,externalConsumeTimeSum=$4,dataSourceId=$3,dateTime=$0),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515523:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],count=$3,externalCount=$6,successSum=$8,externalSuccessSum=$7,consumeTimeSum=$2,externalConsumeTimeSum=$5,dataSourceId=$4,dateTime=$1),
 rowcount=75.0, cumulative cost={inf}
   >    rel#515482:Subset#5.DRUID.[], best=null, importance=1.0
   >            
rel#515483:AbstractConverter.DRUID.[](input=rel#515481:Subset#5.NONE.[],convention=DRUID,sort=[]),
 rowcount=75.0, cumulative cost={inf}
   > Set#6, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515487:Subset#6.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515484:LogicalProject.NONE.[](input=rel#515477:Subset#3.NONE.[],__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=300.0, cumulative cost={inf}
   >            
rel#515518:LogicalProject.NONE.[](input=rel#515513:Subset#9.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8),
 rowcount=300.0, cumulative cost={inf}
   > Set#7, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, BIGINT 
count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515489:Subset#7.NONE.[], best=null, importance=0.81
   >            
rel#515488:LogicalFilter.NONE.[](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 MILLIS_TO_TIMESTAMP(1529337600000)), <=($0, 
MILLIS_TO_TIMESTAMP(1529510399999)))), importance=0.0, rowcount=75.0, 
cumulative cost={inf}
   >            
rel#515491:LogicalFilter.NONE.[[]](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515495:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=75.0, cumulative cost={inf}
   >            
rel#515500:LogicalFilter.NONE.[](input=rel#515487:Subset#6.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515522:LogicalProject.NONE.[](input=rel#515521:Subset#10.NONE.[],__time=$1,consumeTimeSum=$2,count=$3,dataSourceId=$4,externalConsumeTimeSum=$5,externalCount=$6,externalSuccessSum=$7,successSum=$8),
 rowcount=75.0, cumulative cost={inf}
   > Set#9, type: RecordType(VARCHAR ROW_VALUE, TIMESTAMP(0) __time, DOUBLE 
consumeTimeSum, BIGINT count, VARCHAR dataSourceId, DOUBLE 
externalConsumeTimeSum, BIGINT externalCount, BIGINT externalSuccessSum, BIGINT 
successSum)
   >    rel#515513:Subset#9.NONE.[], best=null, importance=0.6561
   >            
rel#515511:LogicalJoin.NONE.[](left=rel#515632:Subset#1.NONE.[],right=rel#515472:Subset#0.NONE.[],condition==($4,
 $0),joinType=inner), rowcount=300.0, cumulative cost={inf}
   >            
rel#515517:LogicalProject.NONE.[](input=rel#515477:Subset#3.NONE.[],ROW_VALUE=$8,__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=300.0, cumulative cost={inf}
   > Set#10, type: RecordType(VARCHAR ROW_VALUE, TIMESTAMP(0) __time, DOUBLE 
consumeTimeSum, BIGINT count, VARCHAR dataSourceId, DOUBLE 
externalConsumeTimeSum, BIGINT externalCount, BIGINT externalSuccessSum, BIGINT 
successSum)
   >    rel#515521:Subset#10.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515519:LogicalFilter.NONE.[](input=rel#515513:Subset#9.NONE.[],condition=AND(>=($1,
 2018-06-18 16:00:00), <=($1, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515524:LogicalFilter.NONE.[[]](input=rel#515513:Subset#9.NONE.[],condition=AND(>=($1,
 2018-06-18 16:00:00), <=($1, 2018-06-20 16:00:00))), rowcount=75.0, cumulative 
cost={inf}
   >            
rel#515537:LogicalJoin.NONE.[](left=rel#515632:Subset#1.NONE.[],right=rel#515530:Subset#12.NONE.[],condition==($4,
 $0),joinType=inner), rowcount=75.0, cumulative cost={inf}
   >            
rel#515543:LogicalProject.NONE.[](input=rel#515479:Subset#4.NONE.[],ROW_VALUE=$8,__time=$0,consumeTimeSum=$1,count=$2,dataSourceId=$3,externalConsumeTimeSum=$4,externalCount=$5,externalSuccessSum=$6,successSum=$7),
 rowcount=75.0, cumulative cost={inf}
   > Set#12, type: RecordType(TIMESTAMP(0) __time, DOUBLE consumeTimeSum, 
BIGINT count, VARCHAR dataSourceId, DOUBLE externalConsumeTimeSum, BIGINT 
externalCount, BIGINT externalSuccessSum, BIGINT successSum)
   >    rel#515530:Subset#12.NONE.[], best=null, importance=0.7290000000000001
   >            
rel#515528:LogicalFilter.NONE.[[]](input=rel#515472:Subset#0.NONE.[],condition=AND(>=($0,
 2018-06-18 16:00:00), <=($0, 2018-06-20 16:00:00))), rowcount=25.0, cumulative 
cost={inf}
   >            
rel#515634:DruidQueryRel.NONE.[](dataSource=dev-datasource-execution-record,intervals=[2018-06-18T16:00:00.000Z/2018-06-20T16:00:00.001Z]),
 rowcount=1.0, cumulative cost={inf}
   >    rel#515643:Subset#12.DRUID.[], best=rel#515642, 
importance=0.36450000000000005
   >            
rel#515642:DruidQueryRel.DRUID.[](dataSource=dev-datasource-execution-record,intervals=[2018-06-18T16:00:00.000Z/2018-06-20T16:00:00.001Z]),
 rowcount=1.0, cumulative cost={0.1 rows, 0.0 cpu, 0.0 io}

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to