diff --git a/utils/joiner/joinpartition.cpp b/utils/joiner/joinpartition.cpp index 6db3ade42..6db0810cf 100644 --- a/utils/joiner/joinpartition.cpp +++ b/utils/joiner/joinpartition.cpp @@ -849,7 +849,15 @@ uint64_t JoinPartition::writeByteStream(int which, ByteStream& bs) bs.advance(len); offset = fs.tellp(); + fs.close(); + + if (fs.fail()) + { + ostringstream os; + os << "Disk join file " << filename << ": close() failure, probable exhaustion of disk space." << endl; + throw IDBExcept(os.str().c_str(), ERR_DBJ_FILE_IO_ERROR); + } return ret; }