remove unnecessary change

pingcap · Jun 24, 2022 · c551a81 · c551a81
1 parent f8f7206
commit c551a81
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/dbms/src/Storages/DeltaMerge/Segment.cpp b/dbms/src/Storages/DeltaMerge/Segment.cpp
@@ -1333,9 +1333,7 @@ bool Segment::compactDelta(DMContext & dm_context)
     CurrentMetrics::Increment cur_dm_segments{CurrentMetrics::DT_DeltaCompact};
     GET_METRIC(tiflash_storage_subtask_count, type_delta_compact).Increment();
     Stopwatch watch;
-    SCOPE_EXIT({
-        GET_METRIC(tiflash_storage_subtask_duration_seconds, type_delta_compact).Observe(watch.elapsedSeconds());
-    });
+    SCOPE_EXIT({ GET_METRIC(tiflash_storage_subtask_duration_seconds, type_delta_compact).Observe(watch.elapsedSeconds()); });
 
     return delta->compact(dm_context);
 }

diff --git a/dbms/src/Storages/Transaction/RegionTable.cpp b/dbms/src/Storages/Transaction/RegionTable.cpp
@@ -230,10 +230,7 @@ void removeObsoleteDataInStorage(
         auto rowkey_range
             = DM::RowKeyRange::fromRegionRange(handle_range, table_id, table_id, storage->isCommonHandle(), storage->getRowKeyColumnSize());
         dm_storage->deleteRange(rowkey_range, context->getSettingsRef());
-        // flush to disk and keep try until success
-        while (!dm_storage->flushCache(*context, rowkey_range))
-        {
-        }
+        dm_storage->flushCache(*context, rowkey_range); // flush to disk
     }
     catch (DB::Exception & e)
     {