From 2100b2b7ee41096e4306df72666fd010febc60cd Mon Sep 17 00:00:00 2001 From: fengzero Date: Wed, 22 Jul 2026 06:15:06 +0000 Subject: [PATCH] ekuiper: filters no tags write --- plugins/ekuiper/read_write.c | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/plugins/ekuiper/read_write.c b/plugins/ekuiper/read_write.c index 44fb966a6..c7b79e1bd 100644 --- a/plugins/ekuiper/read_write.c +++ b/plugins/ekuiper/read_write.c @@ -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); }