GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-19 05:51:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

ekuiper:add warn log

Browse Source
This commit is contained in:
xiang.zhou
2025-11-19 16:37:11 +08:00
parent 67ed390737
commit bd65073a35
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/read_write.c
+7 -2
View File
@@ -242,8 +242,13 @@ void recv_data_callback(void *arg)
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 (req->plural.n_tag == 0) {
plog_warn(plugin, "no tags to write on node %s",
req->plural.node);
} else {
plog_notice(plugin, "write %d tags on node %s",
req->plural.n_tag, req->plural.node);
}
}
}