diff --git a/be/src/olap/rowset/segcompaction.cpp b/be/src/olap/rowset/segcompaction.cpp index 369a7ccd64..c9485e5500 100644 --- a/be/src/olap/rowset/segcompaction.cpp +++ b/be/src/olap/rowset/segcompaction.cpp @@ -302,7 +302,7 @@ void SegcompactionWorker::compact_segments(SegCompactionCandidatesSharedPtr segm case SEGCOMPACTION_INIT_READER: case SEGCOMPACTION_INIT_WRITER: LOG(WARNING) << "segcompaction failed, try next time:" << status; - return; + break; default: auto ctx = _writer->_context; LOG(WARNING) << "segcompaction fatal, terminating the write job."