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
>
