[
https://issues.apache.org/jira/browse/DRILL-5269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anas updated DRILL-5269:
------------------------
Description:
I am a query that has nested joins. The query fails with the following
exception.
{code}
Message: SYSTEM ERROR: JsonMappingException: No suitable constructor found for
type [simple type, class org.apache.drill.exec.store.direct.DirectSubScan]: can
not instantiate from JSON object (missing default constructor or creator, or
perhaps need to add/enable type information?)
at [Source: {
"pop" : "broadcast-sender",
"@id" : 0,
"receiver-major-fragment" : 1,
"child" : {
"pop" : "project",
"@id" : 1,
"exprs" : [ {
"ref" : "`$f1`",
"expr" : "greater_than(`__measure__10`, 0) "
} ],
"child" : {
"pop" : "nested-loop-join",
"@id" : 2,
"left" : {
"pop" : "selection-vector-remover",
"@id" : 4,
"child" : {
"pop" : "filter",
"@id" : 6,
"child" : {
"pop" : "project",
"@id" : 8,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "`count`"
} ],
"child" : {
"pop" : "DirectSubScan",
"@id" : 10,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"reader" : [ {
"count" : 9977
} ],
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 20.0
},
"expr" : "greater_than(`$f0`, 0) ",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"right" : {
"pop" : "streaming-aggregate",
"@id" : 3,
"child" : {
"pop" : "hash-aggregate",
"@id" : 5,
"child" : {
"pop" : "project",
"@id" : 7,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "cast( ( ( if (booleanOr(equal(`Age_Groups`, '45-54') ,
equal(`Age_Groups`, '55+') ) ) then ('45+' ) else (`Age_Groups` ) end ) )
as VARCHAR(65536) )"
} ],
"child" : {
"pop" : "parquet-row-group-scan",
"@id" : 9,
"userName" : "anas",
"storage" : {
"type" : "file",
"enabled" : true,
"connection" : "file:///",
"config" : null,
"workspaces" : {
"root" : {
"location" : "/",
"writable" : false,
"defaultInputFormat" : null
},
"tmp" : {
"location" : "/tmp",
"writable" : true,
"defaultInputFormat" : null
}
},
"formats" : {
"psv" : {
"type" : "text",
"extensions" : [ "tbl" ],
"delimiter" : "|"
},
"csv" : {
"type" : "text",
"extensions" : [ "csv" ],
"delimiter" : ","
},
"tsv" : {
"type" : "text",
"extensions" : [ "tsv" ],
"delimiter" : "\t"
},
"parquet" : {
"type" : "parquet"
},
"json" : {
"type" : "json",
"extensions" : [ "json" ]
},
"avro" : {
"type" : "avro"
},
"sequencefile" : {
"type" : "sequencefile",
"extensions" : [ "seq" ]
},
"csvh" : {
"type" : "text",
"extensions" : [ "csvh" ],
"extractHeader" : true,
"delimiter" : ","
}
}
},
"entries" : [ {
"path" : "<PATH>",
"start" : 4,
"length" : 724400,
"rowGroupIndex" : 0,
"numRecordsToRead" : 9977
} ],
"columns" : [ "`Age_Groups`" ],
"selectionRoot" : "<PATH>",
"filter" : "true",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"formatConfig" : {
"type" : "parquet"
},
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 9977.0
},
"cardinality" : 1.0,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"groupByExprs" : [ {
"ref" : "`$f0`",
"expr" : "`$f0`"
} ],
"aggrExprs" : [ ],
"cost" : 4988.5
},
"keys" : [ ],
"exprs" : [ {
"ref" : "`__measure__10`",
"expr" : "count(`$f0`) "
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 1.0
},
"conditions" : [ ],
"joinType" : "INNER",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"destinations" : [ {
"minorFragmentId" : 0,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 1,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 2,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 3,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 4,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 5,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
}; line: 30, column: 15] (through reference chain:
org.apache.drill.exec.physical.config.BroadcastSender["child"]->org.apache.drill.exec.physical.config.Project["child"]->org.apache.drill.exec.physical.config.NestedLoopJoinPOP["left"]->org.apache.drill.exec.physical.config.SelectionVectorRemover["child"]->org.apache.drill.exec.physical.config.Filter["child"]->org.apache.drill.exec.physical.config.Project["child"])
Fragment 6:0
[Error Id: 050960f1-44fd-464e-9076-7cbd9a1115f5 on anas-2:31010]
(com.fasterxml.jackson.databind.JsonMappingException) No suitable constructor
found for type [simple type, class
org.apache.drill.exec.store.direct.DirectSubScan]: can not instantiate from
JSON object (missing default constructor or creator, or perhaps need to
add/enable type information?)
at [Source: {
"pop" : "broadcast-sender",
"@id" : 0,
"receiver-major-fragment" : 1,
"child" : {
"pop" : "project",
"@id" : 1,
"exprs" : [ {
"ref" : "`$f1`",
"expr" : "greater_than(`__measure__10`, 0) "
} ],
"child" : {
"pop" : "nested-loop-join",
"@id" : 2,
"left" : {
"pop" : "selection-vector-remover",
"@id" : 4,
"child" : {
"pop" : "filter",
"@id" : 6,
"child" : {
"pop" : "project",
"@id" : 8,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "`count`"
} ],
"child" : {
"pop" : "DirectSubScan",
"@id" : 10,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"reader" : [ {
"count" : 9977
} ],
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 20.0
},
"expr" : "greater_than(`$f0`, 0) ",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"right" : {
"pop" : "streaming-aggregate",
"@id" : 3,
"child" : {
"pop" : "hash-aggregate",
"@id" : 5,
"child" : {
"pop" : "project",
"@id" : 7,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "cast( ( ( if (booleanOr(equal(`Age_Groups`, '45-54') ,
equal(`Age_Groups`, '55+') ) ) then ('45+' ) else (`Age_Groups` ) end ) )
as VARCHAR(65536) )"
} ],
"child" : {
"pop" : "parquet-row-group-scan",
"@id" : 9,
"userName" : "anas",
"storage" : {
"type" : "file",
"enabled" : true,
"connection" : "file:///",
"config" : null,
"workspaces" : {
"root" : {
"location" : "/",
"writable" : false,
"defaultInputFormat" : null
},
"tmp" : {
"location" : "/tmp",
"writable" : true,
"defaultInputFormat" : null
}
},
"formats" : {
"psv" : {
"type" : "text",
"extensions" : [ "tbl" ],
"delimiter" : "|"
},
"csv" : {
"type" : "text",
"extensions" : [ "csv" ],
"delimiter" : ","
},
"tsv" : {
"type" : "text",
"extensions" : [ "tsv" ],
"delimiter" : "\t"
},
"parquet" : {
"type" : "parquet"
},
"json" : {
"type" : "json",
"extensions" : [ "json" ]
},
"avro" : {
"type" : "avro"
},
"sequencefile" : {
"type" : "sequencefile",
"extensions" : [ "seq" ]
},
"csvh" : {
"type" : "text",
"extensions" : [ "csvh" ],
"extractHeader" : true,
"delimiter" : ","
}
}
},
"entries" : [ {
"path" : "<PATH>",
"start" : 4,
"length" : 724400,
"rowGroupIndex" : 0,
"numRecordsToRead" : 9977
} ],
"columns" : [ "`Age_Groups`" ],
"selectionRoot" : "<PATH>",
"filter" : "true",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"formatConfig" : {
"type" : "parquet"
},
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 9977.0
},
"cardinality" : 1.0,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"groupByExprs" : [ {
"ref" : "`$f0`",
"expr" : "`$f0`"
} ],
"aggrExprs" : [ ],
"cost" : 4988.5
},
"keys" : [ ],
"exprs" : [ {
"ref" : "`__measure__10`",
"expr" : "count(`$f0`) "
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 1.0
},
"conditions" : [ ],
"joinType" : "INNER",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"destinations" : [ {
"minorFragmentId" : 0,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 1,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 2,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 3,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 4,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 5,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
}; line: 30, column: 15] (through reference chain:
org.apache.drill.exec.physical.config.BroadcastSender["child"]->org.apache.drill.exec.physical.config.Project["child"]->org.apache.drill.exec.physical.config.NestedLoopJoinPOP["left"]->org.apache.drill.exec.physical.config.SelectionVectorRemover["child"]->org.apache.drill.exec.physical.config.Filter["child"]->org.apache.drill.exec.physical.config.Project["child"])
com.fasterxml.jackson.databind.JsonMappingException.from():216
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1130
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize():42
com.fasterxml.jackson.databind.ObjectReader._bindAndClose():1575
com.fasterxml.jackson.databind.ObjectReader.readValue():1200
org.apache.drill.exec.planner.PhysicalPlanReader.readFragmentOperator():94
org.apache.drill.exec.work.fragment.FragmentExecutor.run():203
org.apache.drill.common.SelfCleaningRunnable.run():38
java.util.concurrent.ThreadPoolExecutor.runWorker():1142
java.util.concurrent.ThreadPoolExecutor$Worker.run():617
java.lang.Thread.run():745
{code}
was:
I am a query that has nested joins. The query fails with the following
exception.
{code}
Message: SYSTEM ERROR: JsonMappingException: No suitable constructor found for
type [simple type, class org.apache.drill.exec.store.direct.DirectSubScan]: can
not instantiate from JSON object (missing default constructor or creator, or
perhaps need to add/enable type information?)
at [Source: {
"pop" : "broadcast-sender",
"@id" : 0,
"receiver-major-fragment" : 1,
"child" : {
"pop" : "project",
"@id" : 1,
"exprs" : [ {
"ref" : "`$f1`",
"expr" : "greater_than(`__measure__10`, 0) "
} ],
"child" : {
"pop" : "nested-loop-join",
"@id" : 2,
"left" : {
"pop" : "selection-vector-remover",
"@id" : 4,
"child" : {
"pop" : "filter",
"@id" : 6,
"child" : {
"pop" : "project",
"@id" : 8,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "`count`"
} ],
"child" : {
"pop" : "DirectSubScan",
"@id" : 10,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"reader" : [ {
"count" : 9977
} ],
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 20.0
},
"expr" : "greater_than(`$f0`, 0) ",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"right" : {
"pop" : "streaming-aggregate",
"@id" : 3,
"child" : {
"pop" : "hash-aggregate",
"@id" : 5,
"child" : {
"pop" : "project",
"@id" : 7,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "cast( ( ( if (booleanOr(equal(`Age_Groups`, '45-54') ,
equal(`Age_Groups`, '55+') ) ) then ('45+' ) else (`Age_Groups` ) end ) )
as VARCHAR(65536) )"
} ],
"child" : {
"pop" : "parquet-row-group-scan",
"@id" : 9,
"userName" : "anas",
"storage" : {
"type" : "file",
"enabled" : true,
"connection" : "file:///",
"config" : null,
"workspaces" : {
"root" : {
"location" : "/",
"writable" : false,
"defaultInputFormat" : null
},
"tmp" : {
"location" : "/tmp",
"writable" : true,
"defaultInputFormat" : null
}
},
"formats" : {
"psv" : {
"type" : "text",
"extensions" : [ "tbl" ],
"delimiter" : "|"
},
"csv" : {
"type" : "text",
"extensions" : [ "csv" ],
"delimiter" : ","
},
"tsv" : {
"type" : "text",
"extensions" : [ "tsv" ],
"delimiter" : "\t"
},
"parquet" : {
"type" : "parquet"
},
"json" : {
"type" : "json",
"extensions" : [ "json" ]
},
"avro" : {
"type" : "avro"
},
"sequencefile" : {
"type" : "sequencefile",
"extensions" : [ "seq" ]
},
"csvh" : {
"type" : "text",
"extensions" : [ "csvh" ],
"extractHeader" : true,
"delimiter" : ","
}
}
},
"entries" : [ {
"path" :
"/Applications/IncortaAnalytics/estuate/Incorta_V2.1/tenants/demo/parquet/npd/totalchannel",
"start" : 4,
"length" : 724400,
"rowGroupIndex" : 0,
"numRecordsToRead" : 9977
} ],
"columns" : [ "`Age_Groups`" ],
"selectionRoot" :
"file:/Applications/IncortaAnalytics/estuate/Incorta_V2.1/tenants/demo/parquet/npd/totalchannel",
"filter" : "true",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"formatConfig" : {
"type" : "parquet"
},
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 9977.0
},
"cardinality" : 1.0,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"groupByExprs" : [ {
"ref" : "`$f0`",
"expr" : "`$f0`"
} ],
"aggrExprs" : [ ],
"cost" : 4988.5
},
"keys" : [ ],
"exprs" : [ {
"ref" : "`__measure__10`",
"expr" : "count(`$f0`) "
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 1.0
},
"conditions" : [ ],
"joinType" : "INNER",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"destinations" : [ {
"minorFragmentId" : 0,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 1,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 2,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 3,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 4,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 5,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
}; line: 30, column: 15] (through reference chain:
org.apache.drill.exec.physical.config.BroadcastSender["child"]->org.apache.drill.exec.physical.config.Project["child"]->org.apache.drill.exec.physical.config.NestedLoopJoinPOP["left"]->org.apache.drill.exec.physical.config.SelectionVectorRemover["child"]->org.apache.drill.exec.physical.config.Filter["child"]->org.apache.drill.exec.physical.config.Project["child"])
Fragment 6:0
[Error Id: 050960f1-44fd-464e-9076-7cbd9a1115f5 on anas-2:31010]
(com.fasterxml.jackson.databind.JsonMappingException) No suitable constructor
found for type [simple type, class
org.apache.drill.exec.store.direct.DirectSubScan]: can not instantiate from
JSON object (missing default constructor or creator, or perhaps need to
add/enable type information?)
at [Source: {
"pop" : "broadcast-sender",
"@id" : 0,
"receiver-major-fragment" : 1,
"child" : {
"pop" : "project",
"@id" : 1,
"exprs" : [ {
"ref" : "`$f1`",
"expr" : "greater_than(`__measure__10`, 0) "
} ],
"child" : {
"pop" : "nested-loop-join",
"@id" : 2,
"left" : {
"pop" : "selection-vector-remover",
"@id" : 4,
"child" : {
"pop" : "filter",
"@id" : 6,
"child" : {
"pop" : "project",
"@id" : 8,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "`count`"
} ],
"child" : {
"pop" : "DirectSubScan",
"@id" : 10,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"reader" : [ {
"count" : 9977
} ],
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 20.0
},
"expr" : "greater_than(`$f0`, 0) ",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"right" : {
"pop" : "streaming-aggregate",
"@id" : 3,
"child" : {
"pop" : "hash-aggregate",
"@id" : 5,
"child" : {
"pop" : "project",
"@id" : 7,
"exprs" : [ {
"ref" : "`$f0`",
"expr" : "cast( ( ( if (booleanOr(equal(`Age_Groups`, '45-54') ,
equal(`Age_Groups`, '55+') ) ) then ('45+' ) else (`Age_Groups` ) end ) )
as VARCHAR(65536) )"
} ],
"child" : {
"pop" : "parquet-row-group-scan",
"@id" : 9,
"userName" : "anas",
"storage" : {
"type" : "file",
"enabled" : true,
"connection" : "file:///",
"config" : null,
"workspaces" : {
"root" : {
"location" : "/",
"writable" : false,
"defaultInputFormat" : null
},
"tmp" : {
"location" : "/tmp",
"writable" : true,
"defaultInputFormat" : null
}
},
"formats" : {
"psv" : {
"type" : "text",
"extensions" : [ "tbl" ],
"delimiter" : "|"
},
"csv" : {
"type" : "text",
"extensions" : [ "csv" ],
"delimiter" : ","
},
"tsv" : {
"type" : "text",
"extensions" : [ "tsv" ],
"delimiter" : "\t"
},
"parquet" : {
"type" : "parquet"
},
"json" : {
"type" : "json",
"extensions" : [ "json" ]
},
"avro" : {
"type" : "avro"
},
"sequencefile" : {
"type" : "sequencefile",
"extensions" : [ "seq" ]
},
"csvh" : {
"type" : "text",
"extensions" : [ "csvh" ],
"extractHeader" : true,
"delimiter" : ","
}
}
},
"entries" : [ {
"path" :
"/Applications/IncortaAnalytics/estuate/Incorta_V2.1/tenants/demo/parquet/npd/totalchannel",
"start" : 4,
"length" : 724400,
"rowGroupIndex" : 0,
"numRecordsToRead" : 9977
} ],
"columns" : [ "`Age_Groups`" ],
"selectionRoot" :
"file:/Applications/IncortaAnalytics/estuate/Incorta_V2.1/tenants/demo/parquet/npd/totalchannel",
"filter" : "true",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"formatConfig" : {
"type" : "parquet"
},
"cost" : 0.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 9977.0
},
"cardinality" : 1.0,
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"groupByExprs" : [ {
"ref" : "`$f0`",
"expr" : "`$f0`"
} ],
"aggrExprs" : [ ],
"cost" : 4988.5
},
"keys" : [ ],
"exprs" : [ {
"ref" : "`__measure__10`",
"expr" : "count(`$f0`) "
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 1.0
},
"conditions" : [ ],
"joinType" : "INNER",
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
},
"destinations" : [ {
"minorFragmentId" : 0,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 1,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 2,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 3,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 4,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
}, {
"minorFragmentId" : 5,
"endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
} ],
"initialAllocation" : 1000000,
"maxAllocation" : 10000000000,
"cost" : 10.0
}; line: 30, column: 15] (through reference chain:
org.apache.drill.exec.physical.config.BroadcastSender["child"]->org.apache.drill.exec.physical.config.Project["child"]->org.apache.drill.exec.physical.config.NestedLoopJoinPOP["left"]->org.apache.drill.exec.physical.config.SelectionVectorRemover["child"]->org.apache.drill.exec.physical.config.Filter["child"]->org.apache.drill.exec.physical.config.Project["child"])
com.fasterxml.jackson.databind.JsonMappingException.from():216
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1130
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
com.fasterxml.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize():42
com.fasterxml.jackson.databind.ObjectReader._bindAndClose():1575
com.fasterxml.jackson.databind.ObjectReader.readValue():1200
org.apache.drill.exec.planner.PhysicalPlanReader.readFragmentOperator():94
org.apache.drill.exec.work.fragment.FragmentExecutor.run():203
org.apache.drill.common.SelfCleaningRunnable.run():38
java.util.concurrent.ThreadPoolExecutor.runWorker():1142
java.util.concurrent.ThreadPoolExecutor$Worker.run():617
java.lang.Thread.run():745
{code}
> SYSTEM ERROR: JsonMappingException: No suitable constructor found for type
> [simple type, class org.apache.drill.exec.store.direct.DirectSubScan]
> ------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: DRILL-5269
> URL: https://issues.apache.org/jira/browse/DRILL-5269
> Project: Apache Drill
> Issue Type: Bug
> Affects Versions: 1.9.0
> Reporter: Anas
> Priority: Critical
>
> I am a query that has nested joins. The query fails with the following
> exception.
> {code}
> Message: SYSTEM ERROR: JsonMappingException: No suitable constructor found
> for type [simple type, class
> org.apache.drill.exec.store.direct.DirectSubScan]: can not instantiate from
> JSON object (missing default constructor or creator, or perhaps need to
> add/enable type information?)
> at [Source: {
> "pop" : "broadcast-sender",
> "@id" : 0,
> "receiver-major-fragment" : 1,
> "child" : {
> "pop" : "project",
> "@id" : 1,
> "exprs" : [ {
> "ref" : "`$f1`",
> "expr" : "greater_than(`__measure__10`, 0) "
> } ],
> "child" : {
> "pop" : "nested-loop-join",
> "@id" : 2,
> "left" : {
> "pop" : "selection-vector-remover",
> "@id" : 4,
> "child" : {
> "pop" : "filter",
> "@id" : 6,
> "child" : {
> "pop" : "project",
> "@id" : 8,
> "exprs" : [ {
> "ref" : "`$f0`",
> "expr" : "`count`"
> } ],
> "child" : {
> "pop" : "DirectSubScan",
> "@id" : 10,
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "reader" : [ {
> "count" : 9977
> } ],
> "cost" : 0.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 20.0
> },
> "expr" : "greater_than(`$f0`, 0) ",
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "right" : {
> "pop" : "streaming-aggregate",
> "@id" : 3,
> "child" : {
> "pop" : "hash-aggregate",
> "@id" : 5,
> "child" : {
> "pop" : "project",
> "@id" : 7,
> "exprs" : [ {
> "ref" : "`$f0`",
> "expr" : "cast( ( ( if (booleanOr(equal(`Age_Groups`, '45-54')
> , equal(`Age_Groups`, '55+') ) ) then ('45+' ) else (`Age_Groups` ) end )
> ) as VARCHAR(65536) )"
> } ],
> "child" : {
> "pop" : "parquet-row-group-scan",
> "@id" : 9,
> "userName" : "anas",
> "storage" : {
> "type" : "file",
> "enabled" : true,
> "connection" : "file:///",
> "config" : null,
> "workspaces" : {
> "root" : {
> "location" : "/",
> "writable" : false,
> "defaultInputFormat" : null
> },
> "tmp" : {
> "location" : "/tmp",
> "writable" : true,
> "defaultInputFormat" : null
> }
> },
> "formats" : {
> "psv" : {
> "type" : "text",
> "extensions" : [ "tbl" ],
> "delimiter" : "|"
> },
> "csv" : {
> "type" : "text",
> "extensions" : [ "csv" ],
> "delimiter" : ","
> },
> "tsv" : {
> "type" : "text",
> "extensions" : [ "tsv" ],
> "delimiter" : "\t"
> },
> "parquet" : {
> "type" : "parquet"
> },
> "json" : {
> "type" : "json",
> "extensions" : [ "json" ]
> },
> "avro" : {
> "type" : "avro"
> },
> "sequencefile" : {
> "type" : "sequencefile",
> "extensions" : [ "seq" ]
> },
> "csvh" : {
> "type" : "text",
> "extensions" : [ "csvh" ],
> "extractHeader" : true,
> "delimiter" : ","
> }
> }
> },
> "entries" : [ {
> "path" : "<PATH>",
> "start" : 4,
> "length" : 724400,
> "rowGroupIndex" : 0,
> "numRecordsToRead" : 9977
> } ],
> "columns" : [ "`Age_Groups`" ],
> "selectionRoot" : "<PATH>",
> "filter" : "true",
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "formatConfig" : {
> "type" : "parquet"
> },
> "cost" : 0.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 9977.0
> },
> "cardinality" : 1.0,
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "groupByExprs" : [ {
> "ref" : "`$f0`",
> "expr" : "`$f0`"
> } ],
> "aggrExprs" : [ ],
> "cost" : 4988.5
> },
> "keys" : [ ],
> "exprs" : [ {
> "ref" : "`__measure__10`",
> "expr" : "count(`$f0`) "
> } ],
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 1.0
> },
> "conditions" : [ ],
> "joinType" : "INNER",
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "destinations" : [ {
> "minorFragmentId" : 0,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 1,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 2,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 3,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 4,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 5,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> } ],
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> }; line: 30, column: 15] (through reference chain:
> org.apache.drill.exec.physical.config.BroadcastSender["child"]->org.apache.drill.exec.physical.config.Project["child"]->org.apache.drill.exec.physical.config.NestedLoopJoinPOP["left"]->org.apache.drill.exec.physical.config.SelectionVectorRemover["child"]->org.apache.drill.exec.physical.config.Filter["child"]->org.apache.drill.exec.physical.config.Project["child"])
> Fragment 6:0
> [Error Id: 050960f1-44fd-464e-9076-7cbd9a1115f5 on anas-2:31010]
> (com.fasterxml.jackson.databind.JsonMappingException) No suitable
> constructor found for type [simple type, class
> org.apache.drill.exec.store.direct.DirectSubScan]: can not instantiate from
> JSON object (missing default constructor or creator, or perhaps need to
> add/enable type information?)
> at [Source: {
> "pop" : "broadcast-sender",
> "@id" : 0,
> "receiver-major-fragment" : 1,
> "child" : {
> "pop" : "project",
> "@id" : 1,
> "exprs" : [ {
> "ref" : "`$f1`",
> "expr" : "greater_than(`__measure__10`, 0) "
> } ],
> "child" : {
> "pop" : "nested-loop-join",
> "@id" : 2,
> "left" : {
> "pop" : "selection-vector-remover",
> "@id" : 4,
> "child" : {
> "pop" : "filter",
> "@id" : 6,
> "child" : {
> "pop" : "project",
> "@id" : 8,
> "exprs" : [ {
> "ref" : "`$f0`",
> "expr" : "`count`"
> } ],
> "child" : {
> "pop" : "DirectSubScan",
> "@id" : 10,
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "reader" : [ {
> "count" : 9977
> } ],
> "cost" : 0.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 20.0
> },
> "expr" : "greater_than(`$f0`, 0) ",
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "right" : {
> "pop" : "streaming-aggregate",
> "@id" : 3,
> "child" : {
> "pop" : "hash-aggregate",
> "@id" : 5,
> "child" : {
> "pop" : "project",
> "@id" : 7,
> "exprs" : [ {
> "ref" : "`$f0`",
> "expr" : "cast( ( ( if (booleanOr(equal(`Age_Groups`, '45-54')
> , equal(`Age_Groups`, '55+') ) ) then ('45+' ) else (`Age_Groups` ) end )
> ) as VARCHAR(65536) )"
> } ],
> "child" : {
> "pop" : "parquet-row-group-scan",
> "@id" : 9,
> "userName" : "anas",
> "storage" : {
> "type" : "file",
> "enabled" : true,
> "connection" : "file:///",
> "config" : null,
> "workspaces" : {
> "root" : {
> "location" : "/",
> "writable" : false,
> "defaultInputFormat" : null
> },
> "tmp" : {
> "location" : "/tmp",
> "writable" : true,
> "defaultInputFormat" : null
> }
> },
> "formats" : {
> "psv" : {
> "type" : "text",
> "extensions" : [ "tbl" ],
> "delimiter" : "|"
> },
> "csv" : {
> "type" : "text",
> "extensions" : [ "csv" ],
> "delimiter" : ","
> },
> "tsv" : {
> "type" : "text",
> "extensions" : [ "tsv" ],
> "delimiter" : "\t"
> },
> "parquet" : {
> "type" : "parquet"
> },
> "json" : {
> "type" : "json",
> "extensions" : [ "json" ]
> },
> "avro" : {
> "type" : "avro"
> },
> "sequencefile" : {
> "type" : "sequencefile",
> "extensions" : [ "seq" ]
> },
> "csvh" : {
> "type" : "text",
> "extensions" : [ "csvh" ],
> "extractHeader" : true,
> "delimiter" : ","
> }
> }
> },
> "entries" : [ {
> "path" : "<PATH>",
> "start" : 4,
> "length" : 724400,
> "rowGroupIndex" : 0,
> "numRecordsToRead" : 9977
> } ],
> "columns" : [ "`Age_Groups`" ],
> "selectionRoot" : "<PATH>",
> "filter" : "true",
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "formatConfig" : {
> "type" : "parquet"
> },
> "cost" : 0.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 9977.0
> },
> "cardinality" : 1.0,
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "groupByExprs" : [ {
> "ref" : "`$f0`",
> "expr" : "`$f0`"
> } ],
> "aggrExprs" : [ ],
> "cost" : 4988.5
> },
> "keys" : [ ],
> "exprs" : [ {
> "ref" : "`__measure__10`",
> "expr" : "count(`$f0`) "
> } ],
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 1.0
> },
> "conditions" : [ ],
> "joinType" : "INNER",
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> },
> "destinations" : [ {
> "minorFragmentId" : 0,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 1,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 2,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 3,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 4,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> }, {
> "minorFragmentId" : 5,
> "endpoint" : "CgZhbmFzLTIQovIBGKPyASCk8gE="
> } ],
> "initialAllocation" : 1000000,
> "maxAllocation" : 10000000000,
> "cost" : 10.0
> }; line: 30, column: 15] (through reference chain:
> org.apache.drill.exec.physical.config.BroadcastSender["child"]->org.apache.drill.exec.physical.config.Project["child"]->org.apache.drill.exec.physical.config.NestedLoopJoinPOP["left"]->org.apache.drill.exec.physical.config.SelectionVectorRemover["child"]->org.apache.drill.exec.physical.config.Filter["child"]->org.apache.drill.exec.physical.config.Project["child"])
> com.fasterxml.jackson.databind.JsonMappingException.from():216
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1130
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
>
> com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
>
> com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
>
> com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
>
> com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
>
> com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
>
> com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
>
> com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
>
> com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
>
> com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
>
> com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
>
> com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
>
> com.fasterxml.jackson.databind.deser.SettableBeanProperty.deserialize():488
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeWithErrorWrapping():465
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():380
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1123
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():298
>
> com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1094
>
> com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():166
> com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():135
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():120
>
> com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():91
>
> com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():142
>
> com.fasterxml.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize():42
> com.fasterxml.jackson.databind.ObjectReader._bindAndClose():1575
> com.fasterxml.jackson.databind.ObjectReader.readValue():1200
> org.apache.drill.exec.planner.PhysicalPlanReader.readFragmentOperator():94
> org.apache.drill.exec.work.fragment.FragmentExecutor.run():203
> org.apache.drill.common.SelfCleaningRunnable.run():38
> java.util.concurrent.ThreadPoolExecutor.runWorker():1142
> java.util.concurrent.ThreadPoolExecutor$Worker.run():617
> java.lang.Thread.run():745
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
