[
https://issues.apache.org/jira/browse/IOTDB-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
刘珍 reopened IOTDB-2373:
-----------------------
ping的通的ip，没有启动mqtt，立即返回错误信息，不卡住。
Msg: 313: Error occurred during executing Trigger#onConfig(TriggerAttributes):
java.net.ConnectException: Connection refused
ping不通的ip，依然卡住。
> [Trigger] MQTTSink: there should be a timeout rule
> --------------------------------------------------
>
> Key: IOTDB-2373
> URL: https://issues.apache.org/jira/browse/IOTDB-2373
> Project: Apache IoTDB
> Issue Type: Bug
> Components: Core/Server
> Affects Versions: 0.13.0-SNAPSHOT
> Reporter: 刘珍
> Assignee: xieqijun
> Priority: Major
> Labels: 0.13.0, pull-request-available
> Attachments: TriggerExample.jar
>
>
> 触发器应该有超时规则。
> 并且，创建等待的时候，不阻塞后面触发器的创建。
> 比如，我创建一个触发器，连接的mqtt服务没有启动或者mqtt的ip写错了，
> 这个触发器会一直卡着，
> 后面正确创建的触发器会一直卡着。
> 更严重的是，重启iotdb也会一直卡着。
> 我需要删除data文件夹，重来才可以。
> set storage group to root.sg1;
> CREATE TIMESERIES root.sg1.dev1.s_1 WITH DATATYPE=DOUBLE, ENCODING=PLAIN;
> CREATE TIMESERIES root.sg1.dev1.s_2 WITH DATATYPE=DOUBLE, ENCODING=PLAIN;
> CREATE TIMESERIES root.sg1.dev1.s_3 WITH DATATYPE=DOUBLE, ENCODING=PLAIN;
> CREATE TIMESERIES root.sg1.dev1.s_4 WITH DATATYPE=DOUBLE, ENCODING=PLAIN;
> CREATE TIMESERIES root.sg1.dev1.s_5 WITH DATATYPE=DOUBLE, ENCODING=PLAIN;
> CREATE TIMESERIES root.sg1.dev1.s_6 WITH DATATYPE=DOUBLE, ENCODING=PLAIN;
> //下面的触发器中的remote_ip写错了，卡着
> CREATE TRIGGER "after_trig1"
> AFTER INSERT
> ON root.sg1.dev1.s_1
> AS 'TriggerExample'
> WITH (
> 'trig_name'='after_trig1',
> 'ts_type' = 'double',
> 'remote_ip' = '192.168.130.3',
> 'target_device'='root.lz.alerting',
> 'window_size'='10'
> );
> //再开启cli，创建正确的触发器，卡着
> CREATE TRIGGER "after_trig2"
> AFTER INSERT
> ON root.sg1.dev1.s_2
> AS 'TriggerExample'
> WITH (
> 'trig_name'='after_trig2',
> 'ts_type' = 'double',
> 'remote_ip' = '192.168.130.1',
> 'target_device'='root.lz.alerting',
> 'window_size'='10'
> );
> 重启iotdb，卡着。
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
