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/

Reply via email to