Hi Vinay, could you provide the full stack trace and the Data types you are using in your streaming application, to fully understand the problem?
Regards, Robert On Fri, Aug 25, 2017 at 6:51 PM, vinay patil <vinay18.pa...@gmail.com> wrote: > 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. >
