Hi Shashank, enabling Avro as the default de/serializer for Flink should be as simple as the following, according to [1]
val env = StreamExecutionEnvironment.getExecutionEnvironment env.getConfig.enableForceAvro() I am, however, no expert on this and the implications regarding the use of Avro from inside Scala, so I included Gordon (cc'd) who may know more. Nico [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/ types_serialization.html On Saturday, 23 September 2017 10:11:28 CEST shashank agarwal wrote: > Hello Team, > > As our schema evolves due to business logics. We want to use expendable > schema like Avro as default serializer and deserializer for flink program > and states. > > My doubt is, We are using Scala API in our flink program, But Avro default > supports Java POJO. So how we can use this in our scala APi should we have > to use serializer like Avro4s ? Or we can use default Avro in our Scala > flink app than what will be the steps ? > > Please guide.
