From 9f35e91b8fd4c9fab942e987fed9e5ffc9f7ed7f Mon Sep 17 00:00:00 2001 From: eeff <33566201+eeff@users.noreply.github.com> Date: Wed, 29 May 2024 14:27:09 +0800 Subject: [PATCH] fix(ekuiper): update trans_data metric only when plugin is started --- plugins/ekuiper/plugin_ekuiper.c | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/plugins/ekuiper/plugin_ekuiper.c b/plugins/ekuiper/plugin_ekuiper.c index 43245603..d047d08e 100644 --- a/plugins/ekuiper/plugin_ekuiper.c +++ b/plugins/ekuiper/plugin_ekuiper.c @@ -322,9 +322,13 @@ static int ekuiper_plugin_request(neu_plugin_t * plugin, case NEU_REQRESP_TRANS_DATA: { neu_reqresp_trans_data_t *trans_data = data; - NEU_PLUGIN_UPDATE_METRIC(plugin, NEU_METRIC_TRANS_DATA_5S, 1, NULL); - NEU_PLUGIN_UPDATE_METRIC(plugin, NEU_METRIC_TRANS_DATA_30S, 1, NULL); - NEU_PLUGIN_UPDATE_METRIC(plugin, NEU_METRIC_TRANS_DATA_60S, 1, NULL); + if (plugin->started) { + NEU_PLUGIN_UPDATE_METRIC(plugin, NEU_METRIC_TRANS_DATA_5S, 1, NULL); + NEU_PLUGIN_UPDATE_METRIC(plugin, NEU_METRIC_TRANS_DATA_30S, 1, + NULL); + NEU_PLUGIN_UPDATE_METRIC(plugin, NEU_METRIC_TRANS_DATA_60S, 1, + NULL); + } if (disconnected) { plog_debug(plugin, "not connected");