diff --git a/src/api.js b/src/api.js
index e3f24c3..ae2b42a 100644
--- a/src/api.js
+++ b/src/api.js
@@ -47,6 +47,13 @@ export async function flushIndex() {
   return data
 }
 
+export async function fetchFlushStatus() {
+  const { data } = await axios.get(`${BASE}/admin/flush/status`, {
+    timeout: 5000,
+  })
+  return data
+}
+
 export async function fetchWorkers() {
   const { data } = await axios.get(`${BASE}/admin/workers`, {
     timeout: 10000,
diff --git a/src/views/Dashboard.vue b/src/views/Dashboard.vue
index e235afc..76a30da 100644
--- a/src/views/Dashboard.vue
+++ b/src/views/Dashboard.vue
@@ -1,6 +1,6 @@
 <script setup>
 import { ref, onMounted, onUnmounted } from 'vue'
-import { fetchStats, flushIndex, fetchWorkers, setWorkers, fetchBacklink, triggerBacklink, fetchPriorityStatus } from '../api.js'
+import { fetchStats, flushIndex, fetchFlushStatus, fetchWorkers, setWorkers, fetchBacklink, triggerBacklink, fetchPriorityStatus } from '../api.js'
 
 const stats = ref(null)
 const loading = ref(true)
@@ -131,7 +131,13 @@ async function doFlush() {
   flushing.value = true
   try {
     await flushIndex()
-    // 重新拉取 stats，pending 应该归零
+    // 轮询刷盘状态，直到完成
+    while (true) {
+      await new Promise(r => setTimeout(r, 500)) // 等待 500ms
+      const status = await fetchFlushStatus()
+      if (!status.flushing) break
+    }
+    // 刷盘完成，重新拉取 stats
     stats.value = await fetchStats()
   } catch (e) {
     error.value = '刷盘失败: ' + e.message