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);
             }