diff --git a/lang/c++/impl/DataFile.cc b/lang/c++/impl/DataFile.cc index b0c574630fa..32f27ff2230 100644 --- a/lang/c++/impl/DataFile.cc +++ b/lang/c++/impl/DataFile.cc @@ -118,9 +118,12 @@ void DataFileWriterBase::init(const ValidSchema &schema, size_t syncInterval, co lastSync_ = stream_->byteCount(); } -DataFileWriterBase::~DataFileWriterBase() { +DataFileWriterBase::~DataFileWriterBase() +{ if (stream_) { - close(); + try { + close(); + } catch(...) {} } }