Replies: 1 comment
-
It seems portable plugin is not adapted to the "test connection" interface so the feature is not working. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I try to create a sink plugin
{ "about": { "trial": false, "author": { "name": "J", "email": "xxx", "company": "xxx" }, "description": { "en_US": "This a plugin for k-v state." } }, "libs": [], "properties": [ { "name": "key", "default": "default", "optional": true, "control": "text", "type": "string", "hint": { "en_US": "the interval which you want to send data to mongodb." }, "label": { "en_US": "state key", "zh_CN": "存储键" } } ] }
but when i press this "test connection" button on ekuiper-manager, got ERROR is:
receive error: invalid arg &{stateGo 0x40000a3080 sink map[bufferLength:1024 enableCache:false format:json key:default omitIfEmpty:false runAsync:false sendSingle:true]}, ruleId and opId are required
this is my code snippet
I am puzzled and hope to get some answers.
Eager for reply, Thanks.
Beta Was this translation helpful? Give feedback.
All reactions