[DRILL-4277] Jdbc Storage Plugin doesn't correctly add metadata for physical serialization

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Assignee: Jacques Nadeau
• Reporter: Jacques Nadeau
• Created: 15/Jan/16 19:44
• Updated: 20/Jan/16 15:32
• Resolved: 20/Jan/16 15:32

Description

Example Trace:

Error: SYSTEM ERROR: IllegalStateException: Already had POJO for id
(java.lang.Integer)
[com.fasterxml.jackson.annotation.ObjectIdGenerator$IdKey@3372bbe8]*

*Fragment 2:0*

*[Error Id: 57494209-04e8-4580-860d-461cf50b41f8 on
ip-x-x-x-x.ec2.internal:31010]*

*  (com.fasterxml.jackson.databind.JsonMappingException) Already had POJO
for id (java.lang.Integer)
[com.fasterxml.jackson.annotation.ObjectIdGenerator$IdKey@3372bbe8]
(through reference chain:
org.apache.drill.exec.physical.config.BroadcastSender["destinations"])*
*    com.fasterxml.jackson.databind.JsonMappingException.wrapWithPath():210*
*    com.fasterxml.jackson.databind.JsonMappingException.wrapWithPath():177*
*
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.wrapAndThrow():1420*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():351*
*
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1056*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():264*
*
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1028*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():154*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():126*
*
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():113*
*
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():84*
*
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():132*
*
com.fasterxml.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize():41*
*    com.fasterxml.jackson.databind.ObjectReader._bindAndClose():1269*
*    com.fasterxml.jackson.databind.ObjectReader.readValue():896*
*
org.apache.drill.exec.planner.PhysicalPlanReader.readFragmentOperator():94*
*    org.apache.drill.exec.work.fragment.FragmentExecutor.run():227*
*    org.apache.drill.common.SelfCleaningRunnable.run():38*
*    java.util.concurrent.ThreadPoolExecutor.runWorker():1145*
*    java.util.concurrent.ThreadPoolExecutor$Worker.run():615*
*    java.lang.Thread.run():745*
*  Caused By (java.lang.IllegalStateException) Already had POJO for id
(java.lang.Integer)
[com.fasterxml.jackson.annotation.ObjectIdGenerator$IdKey@3372bbe8]*
*    com.fasterxml.jackson.annotation.SimpleObjectIdResolver.bindItem():20*
*
com.fasterxml.jackson.databind.deser.impl.ReadableObjectId.bindItem():66*
*
com.fasterxml.jackson.databind.deser.impl.PropertyValueBuffer.handleIdValue():117*
*
com.fasterxml.jackson.databind.deser.impl.PropertyBasedCreator.build():169*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased():349*
*
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault():1056*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject():264*
*
com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeWithObjectId():1028*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther():154*
*
com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize():126*
*
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer._deserializeTypedForId():113*
*
com.fasterxml.jackson.databind.jsontype.impl.AsPropertyTypeDeserializer.deserializeTypedFromObject():84*
*
com.fasterxml.jackson.databind.deser.AbstractDeserializer.deserializeWithType():132*
*
com.fasterxml.jackson.databind.deser.impl.TypeWrappedDeserializer.deserialize():41*
*    com.fasterxml.jackson.databind.ObjectReader._bindAndClose():1269*
*    com.fasterxml.jackson.databind.ObjectReader.readValue():896*
*
org.apache.drill.exec.planner.PhysicalPlanReader.readFragmentOperator():94*
*    org.apache.drill.exec.work.fragment.FragmentExecutor.run():227*
*    org.apache.drill.common.SelfCleaningRunnable.run():38*
*    java.util.concurrent.ThreadPoolExecutor.runWorker():1145*
*    java.util.concurrent.ThreadPoolExecutor$Worker.run():615*
*    java.lang.Thread.run():745 (state=,code=0)*