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