apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Priyanka Gugale <pri...@apache.org>
Subject Re: Kyrp exception
Date Thu, 08 Sep 2016 09:37:50 GMT
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 <jjilka@leadferret.com> wrote:

> I am using 3.5.0-snapshot malhar library.
>
> ----- Original Message -----
> From: "Thomas Weise" <thomas.weise@gmail.com>
> To: "users" <users@apex.apache.org>
> 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 <jjilka@leadferret.com>
> 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" <pramod@datatorrent.com>
> > To: "users" <users@apex.apache.org>
> > 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 <jjilka@leadferret.com>
> > 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
> > >
> >
>

Mime
View raw message