hi Regina I've just been using flink, and recently I've been asked to store Flink data on HDFS in parquet format. I've found several examples in GitHub and the community, but there are always bugs. I see your storage directory, and that's what I want, so I'd like to ask you to reply to me for a slightly more complete one. Some examples.
The result is similar to the following: 237.6 M <folder_name>/19_partMapper-m-00018.snappy.parquet 240.7 M <folder_name>/1_partMapper-m-00009.snappy.parquet 240.7 M <folder_name>/20_partMapper-m-00008.snappy.parquet 236.5 M <folder_name>/2_partMapper-m-00020.snappy.parquet I look forward to your reply. Thank you very much! -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/