GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-17 04:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2613 from ZhouBox/v2.11

Browse Source 
[v2.11]ekuiper:add log
This commit is contained in:
fengzeroz
2025-11-19 11:03:29 +08:00
committed by GitHub
parent bfcd62252f f5191248b5
commit 09c21bde58
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/read_write.c
+8
View File
@@ -234,9 +234,17 @@ void recv_data_callback(void *arg)
if (req->singular) {
rv = send_write_tag_req(plugin, &req->single, json_str, trace_flag,
trace_id, span_id);
if (rv == 0) {
plog_notice(plugin, "write tag %s.%s on node %s", req->single.group,
req->single.tag, req->single.node);
}
} else {
rv = send_write_tags_req(plugin, &req->plural, json_str, trace_flag,
trace_id, span_id);
if (rv == 0) {
plog_notice(plugin, "write %d tags on node %s", req->plural.n_tag,
req->plural.node);
}
}
if (0 != rv) {