Hi Guys, I am using DataStreamUtils for unit testing, the test case succeeds when it is run individually but I get the following error when all the tests are run:
Serialization trace: fieldMap (org.apache.avro.Schema$RecordSchema) schema (org.apache.avro.generic.GenericData$Record) at org.apache.flink.contrib.streaming.SocketStreamIterator.hasNext(SocketStreamIterator.java:114) I tried to to register the above classes but it did not work. Also this error comes randomly for some tests while some test pass. What could be the issue ? Regards, Vinay Patil -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Serialization-issues-with-DataStreamUtils-tp15139.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.