chore: update docs

2026-01-07 22:02:56 +00:00 · 2025-04-22 11:40:17 +08:00
parent ae00e28b2a
commit 0d0dad4ba2
1 changed files with 1 additions and 0 deletions
--- a/src/flow/src/adapter/flownode_impl.rs
+++ b/src/flow/src/adapter/flownode_impl.rs
@@ -274,6 +274,7 @@ impl FlowDualEngine {
        Ok(())
    }

+    // TODO(discord9): consider sync this with heartbeat(might become necessary in the future)
    pub async fn start_flow_consistent_check_task(self: &Arc<Self>) -> Result<(), Error> {
        let mut check_task = self.check_task.lock().await;
        ensure!(