Re: Parquet format in Flink 1.11

2020-07-15 Thread Flavio Pompermaier
Ok, thanks Godfrey. On Wed, Jul 15, 2020 at 3:03 PM godfrey he wrote: > hi Flavio, > > Parquet format supports configuration from ParquetOutputFormat > . > please > refer to [

Re: Parquet format in Flink 1.11

2020-07-15 Thread godfrey he
hi Flavio, Parquet format supports configuration from ParquetOutputFormat . please refer to [1] for details [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/

Parquet format in Flink 1.11

2020-07-15 Thread Flavio Pompermaier
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.setEnableDictio