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
