From bd65073a359a248793107adfbb583000339eb8ea Mon Sep 17 00:00:00 2001
From: "xiang.zhou" <xiang.zhou@emqx.io>
Date: Wed, 19 Nov 2025 16:37:11 +0800
Subject: [PATCH] ekuiper:add warn log

---
 plugins/ekuiper/read_write.c | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/plugins/ekuiper/read_write.c b/plugins/ekuiper/read_write.c
index 1d5baadd..ed64d5a5 100644
--- a/plugins/ekuiper/read_write.c
+++ b/plugins/ekuiper/read_write.c
@@ -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);
+            }
         }
     }