You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@drill.apache.org by "Anas (JIRA)" <ji...@apache.org> on 2017/02/16 13:09:41 UTC

[jira] [Created] (DRILL-5269) SYSTEM ERROR: JsonMappingException: No suitable constructor found for type [simple type, class org.apache.drill.exec.store.direct.DirectSubScan]

Anas created DRILL-5269:
---------------------------

             Summary: 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" : "/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}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)