Hello, I tried running my application using another table in my database. It is running fine. Not getting any error. The only difference from previous table is I am inserting data into previous table while I am running the application and in this table I am not inserting any data. It has fixed data. So is that the reason for the error? My table type is MyISAM
Thank You, Jaikit Jilka ----- Original Message ----- From: "Jaikit Jilka" <[email protected]> To: "users" <[email protected]> Sent: Thursday, September 8, 2016 10:43:23 AM Subject: Re: Kyrp exception Hello Priyanka, I have made only one change in input opertaor file i.e. added these two case to activate and settuple method case (Types.LONGVARCHAR): case (Types.OTHER): No other changes. I am also attahcing my input operator file If you want to look at it. Thank you, Jaikit Jilka ----- Original Message ----- From: "Priyanka Gugale" <[email protected]> To: "users" <[email protected]> Sent: Thursday, September 8, 2016 2:37:50 AM Subject: Re: Kyrp exception 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 > > > > > >
