Hi Ebru, AvroParquetOutputFormat seems to implement Hadoop's OutputFormat interface. Flink provides a wrapper for Hadoop's OutputFormat [1], so you can try to wrap AvroParquetOutputFormat in Flink's HadoopOutputFormat.
Hope this helps, Fabian [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/batch/hadoop_compatibility.html#using-hadoop-outputformats 2017-11-22 15:21 GMT+01:00 ebru <b20926...@cs.hacettepe.edu.tr>: > Hello all, > > We are trying to write dataset as parquet format, we use > AvroParquetOutputFormat but it is not compatible with Flink’s > FileOutputFormat. > > Is there a way to write dataset as parquet? > > -Ebru
