Hi to all,
in my current code I use the legacy Hadoop Output format to write my
Parquet files.
I wanted to use the new Parquet format of Flink 1.11 but I can't find how
to migrate the following properties:

ParquetOutputFormat.setBlockSize(job, parquetBlockSize);
ParquetOutputFormat.setEnableDictionary(job, true);
ParquetOutputFormat.setCompression(job, CompressionCodecName.SNAPPY);

Is there a way to set those configs?
And if not, is there a way to handle them without modifying the source of
the flink connector (i.e. extending some class)?

Best,
Flavio

Reply via email to