diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs index b4c8f72539..532ea366a6 100644 --- a/src/flow/src/adapter.rs +++ b/src/flow/src/adapter.rs @@ -63,10 +63,14 @@ pub struct FlowNodeManager<'subgraph> { tick_manager: FlowTickManager, } +/// Just check if NodeManager's other fields are `Send` so later we can refactor so A Flow Node Manager +/// can manage multiple flow worker(thread) then we can run multiple flow worker in a single flow node manager #[test] -fn check() { +fn check_is_send() { fn is_send() {} + is_send::(); is_send::(); + is_send::(); } /// mapping of table name <-> table id should be query from tableinfo manager