[fix](load) segcompaction does not signal waiters when an error hanppens (#21043)

This leads to a deadlock.
2023-06-21 14:56:34 +08:00
parent bad22dd4e2
commit c5560b8f93
1 changed files with 1 additions and 1 deletions
--- 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."