GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-28 22:59:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

ekuiper: filters no tags write

Browse Source
This commit is contained in:
fengzero
2026-07-22 06:41:48 +00:00
parent 048cf8dacb
commit 2100b2b7ee
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/read_write.c
+6 -7
View File
@@ -240,13 +240,12 @@ void recv_data_callback(void *arg)
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) {
if (req->plural.n_tag == 0) {
plog_warn(plugin, "no tags to write on node %s",
req->plural.node);
} else {
if (req->plural.n_tag == 0) {
plog_warn(plugin, "no tags to write on node %s", req->plural.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);
}