milvus/internal/util/flowgraph
yihao.dai a57c9e61fc
enhance: [cherry-pick] optimize datanode cpu usage and correct the update logic of ttchecker (#34383)
This PR cherry-picks the following commits:
- Try to improve cpu usage by refactoring the ttchecker logic and
caching string. https://github.com/milvus-io/milvus/pull/33267
- Correct the update logic of timerecorder in the flowgraph to avoid
false failure: "some node(s) haven't received input".
https://github.com/milvus-io/milvus/pull/34339

issue: https://github.com/milvus-io/milvus/issues/33266,
https://github.com/milvus-io/milvus/issues/34337

pr: https://github.com/milvus-io/milvus/pull/33267,
https://github.com/milvus-io/milvus/pull/34339

---------

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
Co-authored-by: Xiaofan <83447078+xiaofan-luan@users.noreply.github.com>
2024-07-04 16:34:17 +08:00
..
flow_graph.go fix: Use determined order to lock in BlockAll to avoid deadlock (#29246) 2024-01-22 14:50:56 +08:00
flow_graph_test.go fix: Use determined order to lock in BlockAll to avoid deadlock (#29246) 2024-01-22 14:50:56 +08:00
input_node.go enhance: [cherry-pick] optimize datanode cpu usage and correct the update logic of ttchecker (#34383) 2024-07-04 16:34:17 +08:00
input_node_test.go enhance: move rocksmq from internal to pkg (#34165) 2024-06-26 13:36:05 +08:00
message.go Move some modules from internal to public package (#22572) 2023-04-06 19:14:32 +08:00
message_test.go Format the code (#27275) 2023-09-21 09:45:27 +08:00
node.go enhance: [cherry-pick] optimize datanode cpu usage and correct the update logic of ttchecker (#34383) 2024-07-04 16:34:17 +08:00
node_test.go enhance: move rocksmq from internal to pkg (#34165) 2024-06-26 13:36:05 +08:00
type_def.go Use go-api/v2 for milvus-proto (#24770) 2023-06-09 01:28:37 +08:00