We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Take following steps to reproduce the problem.
create stream 'demo() WITH (FORMAT="JSON", DATASOURCE="devices/")'
{ "sql": "SELECT * FROM demo", "actions": [ { "log": {} }, { "rest": { "url": "http://localhost:8888", "method": "Get", "dataTemplate": "{\"hello\": 3}", "sendSingle": true } } ] }
{"temperature": 12, "humidity" : 15}
time="2020-05-15T09:02:42+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:02:43+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:02:44+08:00" level=info msg="save cache for rule rule1" file="sink_cache.go:126" rule=rule1 time="2020-05-15T09:02:44+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:02:45+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:02:46+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1
It still print these message even after the rule is drop, bin/cli drop rule rule1
bin/cli drop rule rule1
time="2020-05-15T09:03:40+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:03:40+08:00" level=info msg="sink node sink_log instance 0 done" file="sink_node.go:185" rule=rule1 time="2020-05-15T09:03:40+08:00" level=info msg="unary operator preprocessor_demo instance 0 cancelling...." file="operations.go:153" rule=rule1 time="2020-05-15T09:03:40+08:00" level=info msg="unary operator preprocessor_demo instance 0 done, cancelling future items" file="operations.go:108" rule=rule1 time="2020-05-15T09:03:40+08:00" level=info msg="unary operator project instance 0 cancelling...." file="operations.go:153" rule=rule1 time="2020-05-15T09:03:40+08:00" level=info msg="unary operator project instance 0 done, cancelling future items" file="operations.go:108" rule=rule1 time="2020-05-15T09:03:40+08:00" level=info msg="source demo done" file="source_node.go:119" rule=rule1 time="2020-05-15T09:03:40+08:00" level=info msg="Mqtt Source instance 0 Done" file="mqtt_source.go:175" rule=rule1 time="2020-05-15T09:03:41+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:03:42+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:03:43+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:03:44+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:03:45+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1 time="2020-05-15T09:03:46+08:00" level=warning msg="sink node sink_rest instance 0 publish {\"hello\": 3} error: rest sink fails to err http return code: 404." file="sink_node.go:272" rule=rule1
Any workaround for this? Yes, add retryInterval to avoid keeping trying to re-send the result.
retryInterval
{ "sql": "SELECT * FROM demo", "actions": [ { "log": {} }, { "rest": { "url": "http://localhost:9443", "method": "Get", "retryInterval": -1, "dataTemplate": "{\"hello\": 3}", "sendSingle": true } } ] }
The text was updated successfully, but these errors were encountered:
Fixed & close the issue.
Sorry, something went wrong.
ngjaying
Successfully merging a pull request may close this issue.
Take following steps to reproduce the problem.
{"temperature": 12, "humidity" : 15}
It still print these message even after the rule is drop,
bin/cli drop rule rule1
Any workaround for this? Yes, add
retryInterval
to avoid keeping trying to re-send the result.The text was updated successfully, but these errors were encountered: