Hi Jalkit, Can you tell me which jdbc driver you are using? Also have you done any changes to the operator code? If you can you mention what are those?
-Priyanka On Thu, Sep 8, 2016 at 3:20 AM, Jaikit Jilka <[email protected]> wrote: > I am using 3.5.0-snapshot malhar library. > > ----- Original Message ----- > From: "Thomas Weise" <[email protected]> > To: "users" <[email protected]> > Sent: Wednesday, September 7, 2016 2:39:18 PM > Subject: Re: Kyrp exception > > The stack trace shows that a resultSet field is part of the checkpointed > state. > > I don't see this property in the latest release (3.5.0). Which version of > Malhar are you using? > > On Wed, Sep 7, 2016 at 2:16 PM, Jaikit Jilka <[email protected]> > wrote: > > > Hello, > > > > I did not clearly understand you question but in JDBC input operator I > > have this: > > > > public void setup(Context.PortContext context) > > { > > pojoClass = context.getValue(Context.PortContext.TUPLE_CLASS); > > } > > > > Thank You, > > > > Jaikit Jilka > > > > ----- Original Message ----- > > From: "Pramod Immaneni" <[email protected]> > > To: "users" <[email protected]> > > Sent: Wednesday, September 7, 2016 1:44:09 PM > > Subject: Re: Kyrp exception > > > > Hi Jaikit, > > > > Looks like you have three operators, jdbc input, parser and jdbc output > all > > container local. What is the pojoClass set to in the JDBC input operator? > > > > Thanks > > > > On Wed, Sep 7, 2016 at 1:30 PM, Jaikit Jilka <[email protected]> > > wrote: > > > > > Hello, > > > > > > My application run fine but after sometime it suddenly give me this > > error. > > > > > > java.lang.IllegalStateException: Deploy request failed: > > > [OperatorDeployInfo[id=2,name=Parser,type=GENERIC, > > checkpoint={57d06ff100000167, > > > 0, 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName= > > > PInput,streamId=Input-Parser,sourceNodeId=1,sourcePortName= > > > outputPort,locality=CONTAINER_LOCAL,partitionMask=0, > > > partitionKeys=<null>]],outputs=[OperatorDeployInfo. > > > OutputDeployInfo[portName=Poutput,streamId=Parser- > > Output,bufferServer=<null>]]], > > > OperatorDeployInfo[id=1,name=JdbcInput,type=INPUT, > > checkpoint={57d06ff100000167, > > > 0, 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName= > > > outputPort,streamId=Input-Parser,bufferServer=<null>]]], > > > OperatorDeployInfo[id=3,name=JdbcOutput,type=GENERIC, > > checkpoint={57d06ff100000167, > > > 0, 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName= > > > input,streamId=Parser-Output,sourceNodeId=2,sourcePortName= > > > Poutput,locality=CONTAINER_LOCAL,partitionMask=0, > partitionKeys=<null>]], > > > outputs=[]]] > > > at com.datatorrent.stram.engine.StreamingContainer. > > > processHeartbeatResponse(StreamingContainer.java:823) > > > at com.datatorrent.stram.engine.StreamingContainer. > > heartbeatLoop( > > > StreamingContainer.java:707) > > > at com.datatorrent.stram.engine.StreamingContainer.main( > > > StreamingContainer.java:313) > > > Caused by: com.esotericsoftware.kryo.KryoException: Class cannot be > > > created (missing no-arg constructor): com.mysql.jdbc.JDBC4ResultSet > > > Serialization trace: > > > resultSet (com.datatorrent.lib.db.jdbc.JdbcPOJOInputOperator) > > > at com.esotericsoftware.kryo.Kryo$DefaultInstantiatorStrategy. > > > newInstantiatorOf(Kryo.java:1228) > > > at com.esotericsoftware.kryo.Kryo.newInstantiator(Kryo. > > java:1049) > > > at com.esotericsoftware.kryo.Kryo.newInstance(Kryo.java:1058) > > > at com.esotericsoftware.kryo.serializers.FieldSerializer. > > > create(FieldSerializer.java:547) > > > at com.esotericsoftware.kryo.serializers.FieldSerializer. > > > read(FieldSerializer.java:523) > > > at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:679) > > > at com.esotericsoftware.kryo.serializers.ObjectField.read( > > > ObjectField.java:106) > > > at com.esotericsoftware.kryo.serializers.FieldSerializer. > > > read(FieldSerializer.java:528) > > > at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo. > > > java:761) > > > at com.datatorrent.common.util.FSStorageAgent.retrieve( > > > FSStorageAgent.java:192) > > > at com.datatorrent.common.util.FSStorageAgent.load( > > > FSStorageAgent.java:137) > > > at com.datatorrent.stram.engine.StreamingContainer. > deployNodes( > > > StreamingContainer.java:907) > > > at com.datatorrent.stram.engine.StreamingContainer.deploy( > > > StreamingContainer.java:856) > > > at com.datatorrent.stram.engine.StreamingContainer. > > > processHeartbeatResponse(StreamingContainer.java:814) > > > ... 2 more > > > > > > Have no idea what is it. > > > > > > Thank You, > > > > > > Jaikit Jilka > > > > > >
