[BugFix] Handle parquet exception in sync parquet file writer (StarRo…

…cks#39734) Signed-off-by: Letian Jiang <letian.jiang@outlook.com>
QingdongZeng3 · Jan 23, 2024 · c9c798a · c9c798a
1 parent 250b06e
commit c9c798a
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/be/src/formats/parquet/file_writer.cpp b/be/src/formats/parquet/file_writer.cpp
@@ -424,7 +424,12 @@ Status SyncFileWriter::close() {
     }
 
     RETURN_IF_ERROR(_flush_row_group());
-    _writer->Close();
+    try {
+        _writer->Close();
+    } catch (const ::parquet::ParquetStatusException& e) {
+        LOG(WARNING) << "close writer error: " << e.what();
+        return Status::IOError(fmt::format("{}: {}", "close writer error", e.what()));
+    }
 
     auto arrow_st = _outstream->Close();
     if (!arrow_st.ok()) {