Hi Team
Please find the traces of the problem that I’m facing :
1. Earlier i was connecting the app with my local couch base and every thing
worked fine. There were no such error in connection.
2. Now i am trying to connect my app to live couch base servers and the error
occurs.
3. Main point
You need to put the annotation on the class that wraps the GenericRecord,
not the operator.
I don't know whether GenericRecord is suitable for Java serialization. If
it is, you can try to change your operator to emit KryoJdkContainer instead
(or change the stream codec):
GenericRecord record =
There is some information available here:
http://docs.datatorrent.com/troubleshooting/#application-throwing-following-kryo-exception
If the object is Java serializable, you can set the stream codec or wrap
into KryoJdkContainer:
