fix the problem of not stopping a failed flush correctly (#4187)

close #4185
pingcap · Mar 7, 2022 · 4d8a1be · 4d8a1be
1 parent acae5c1
commit 4d8a1be
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dbms/src/Storages/DeltaMerge/Delta/DeltaValueSpace.cpp b/dbms/src/Storages/DeltaMerge/Delta/DeltaValueSpace.cpp
@@ -180,6 +180,7 @@ bool DeltaValueSpace::flush(DMContext & context)
         {
             wbs.rollbackWrittenLogAndData();
             LOG_FMT_DEBUG(log, "{} Stop flush because structure got updated", simpleInfo());
+            return false;
         }
 
         /// Update delta tree