From 05f5fa85a9b92580724f17506b4bcab010b1a62c Mon Sep 17 00:00:00 2001 From: discord9 Date: Thu, 4 Jul 2024 14:30:03 +0800 Subject: [PATCH] docs: add a todo --- src/operator/src/insert.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/operator/src/insert.rs b/src/operator/src/insert.rs index 51104f738c66..ed7c4fd4f880 100644 --- a/src/operator/src/insert.rs +++ b/src/operator/src/insert.rs @@ -334,7 +334,7 @@ impl Inserter { // already know this is not source table Some(None) => continue, _ => { - // TODO(discord9): determine where to store the flow node address in distributed mode + // TODO(discord9): query metasrv for actual peer address let peers = self .table_flownode_set_cache .get(table_id)