-
Notifications
You must be signed in to change notification settings - Fork 2.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Remove datanode timetick mq, use rpc to report instead #23156
Conversation
@wayblink ut workflow job failed, comment |
@wayblink E2e jenkins job failed, comment |
5fff9ce
to
3423502
Compare
@wayblink ut workflow job failed, comment |
3423502
to
2bc4955
Compare
@wayblink E2e jenkins job failed, comment |
@wayblink ut workflow job failed, comment |
2bc4955
to
2d85800
Compare
@wayblink E2e jenkins job failed, comment |
/run-cpu-e2e |
@wayblink ut workflow job failed, comment |
@wayblink E2e jenkins job failed, comment |
e2c0ad3
to
87e3b58
Compare
@wayblink ut workflow job failed, comment |
87e3b58
to
31a5bad
Compare
Codecov Report
@@ Coverage Diff @@
## master #23156 +/- ##
==========================================
- Coverage 82.44% 82.11% -0.33%
==========================================
Files 779 780 +1
Lines 102453 102681 +228
==========================================
- Hits 84466 84320 -146
- Misses 14972 15316 +344
- Partials 3015 3045 +30
|
@wayblink E2e jenkins job failed, comment |
/run-cpu-e2e |
/assign @XuanYang-cn |
@wayblink E2e jenkins job failed, comment |
@wayblink ut workflow job failed, comment |
51648fc
to
0c0dc91
Compare
@wayblink ut workflow job failed, comment |
0c0dc91
to
f03d369
Compare
@wayblink E2e jenkins job failed, comment |
/run-cpu-e2e |
Signed-off-by: wayblink <anyang.wang@zilliz.com>
f03d369
to
31cf5c9
Compare
@wayblink E2e jenkins job failed, comment |
/run-cpu-e2e |
/run-gpu-e2e |
@wayblink E2e jenkins job failed, comment |
/run-cpu-e2e |
@wayblink E2e jenkins job failed, comment |
/run-cpu-e2e |
/run-gpu-e2e |
/run-gpu-e2e |
/lgtm |
/lgtm |
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: wayblink, xiaofan-luan The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
Signed-off-by: wayblink <anyang.wang@zilliz.com>
Remove timetick mq logic in datacoord and datanode, use RPC instead.
datacoord:
1, Remove DataNodeTtLoop and related msgstream consumer
2, Add ReportDataNodeTtMsgs interface, ReportDataNodeTtMsgs call handleTimetickMessage
datanode:
1, Remove related msgstream producer in flow graph
2, Introduce a timetick_sender in datanode. All insert_buffer_nodes on datanode updates channel states to timetick_sender.
3, timetick_sender call datacoord.ReportDataNodeTtMsgs to send DataNodeTTMsg periodically, perform like heartbeat
related: #22953