Hi all,

When I try to close ParquetWriter, the HDFS throws Exception "Uable to
create new block". Then I try to close it again, the ParquetWriter throws

java.io.IOException: The file being written is in an invalid state.

I look at the code, in the InternalParquetRecordWriter#
flushRowGroupToStore, the state will turn to COLUMN and will not go back to
BLOCK if any exception was thrown by FSOutputStream.

Is there any way that I can close it twice? Since I think the data is still
in the memory or local files.

Best,
Shimin Yang

Reply via email to