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 >
