Hi Sohi, There seems to be no avro implementations of Encoder interface used in StreamingFileSink but maybe it could be implemented based on AvroKeyValueWriter with not such a big effort.
There is also a DefaultRollingPolicy which is based on time and number of records. It might create a temporary files for unfinished results per checkpoint but not in the final result. Best, Andrey On Mon, Feb 25, 2019 at 1:33 PM sohimankotia <sohimanko...@gmail.com> wrote: > Hi Erik, > > I am still not able to understand reason behind this exception. > > Is this exception causing failure and restart of job ? or This is occurring > after failure/restart is triggered . > > > Thanks > Sohi > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
