From 850c378fe4efeb9a8d5ffe7313c49ca377427a47 Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Fri, 22 Apr 2022 10:42:23 +0000
Subject: [PATCH] fix(ekuiper): start from init state

---
 src/adapter/adapter.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c
index 3ee6c872..4b965c5e 100644
--- a/src/adapter/adapter.c
+++ b/src/adapter/adapter.c
@@ -1886,7 +1886,10 @@ int neu_adapter_start(neu_adapter_t *adapter)
     switch (adapter->state) {
     case ADAPTER_STATE_IDLE:
     case ADAPTER_STATE_INIT:
-        error = NEU_ERR_NODE_NOT_READY;
+        if (strncmp(adapter->plugin_info.module->module_name, "ekuiper",
+                    strlen("ekuiper")) != 0) {
+            error = NEU_ERR_NODE_NOT_READY;
+        }
         break;
     case ADAPTER_STATE_RUNNING:
         error = NEU_ERR_NODE_IS_RUNNING;