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 > > >
