check flush result in segment::write

pingcap · May 23, 2022 · 29116a7 · 29116a7
1 parent fea7273
commit 29116a7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/dbms/src/Storages/DeltaMerge/Segment.cpp b/dbms/src/Storages/DeltaMerge/Segment.cpp
@@ -302,7 +302,11 @@ bool Segment::write(DMContext & dm_context, const Block & block, bool flush_cach
     {
         if (flush_cache)
         {
-            flushCache(dm_context);
+            while (!flushCache(dm_context))
+            {
+                if (hasAbandoned())
+                    return false;
+            }
         }
         return true;
     }