GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-16 20:30:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2918 from fengzeroz/v2.14

Browse Source 
ekuiper: filters no tags write
This commit is contained in:
fengzeroz
2026-07-22 15:21:29 +08:00
committed by GitHub
parent 61976061e8 66c5a133db
commit 525dcb78d5
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);
}