Hi Jalkit, I didn't receive the attachment. Can you try to send it again?
-Priyanka On Fri, Sep 9, 2016 at 3:04 AM, Jaikit Jilka <[email protected]> wrote: > 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 > > > > > > > > > >
