diff --git a/be/src/runtime/file_result_writer.cpp b/be/src/runtime/file_result_writer.cpp index ae7f2ff077..f06be0e693 100644 --- a/be/src/runtime/file_result_writer.cpp +++ b/be/src/runtime/file_result_writer.cpp @@ -61,7 +61,7 @@ FileResultWriter::FileResultWriter(const ResultFileOptions* file_opts, } FileResultWriter::~FileResultWriter() { - _close_file_writer(true); + _close_file_writer(true, true); } Status FileResultWriter::init(RuntimeState* state) {