Re: Serialization issues with DataStreamUtils

2017-08-31 Thread vinay patil
Hi, After adding the following two lines the serialization trace does not show the Schema related classes: env.getConfig().registerTypeWithKryoSerializer(GenericData.Array.class, Serializers.SpecificInstanceCollectionSerializerForArrayList.class);

Re: Serialization issues with DataStreamUtils

2017-08-26 Thread vinay patil
) at org.apache.flink.contrib.streaming.SocketStreamIterator.hasNext(SocketStreamIterator.java:112) -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Serialization-issues-with-DataStreamUtils-tp15139p15159.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Serialization issues with DataStreamUtils

2017-08-25 Thread Robert Metzger
ards, > 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. >

Serialization issues with DataStreamUtils

2017-08-25 Thread vinay patil
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.