规则引擎Rule Engine

    常见问题及解答(FAQ)

    排查流式计算任务没有输出的步骤

    1. 确保你的任务已经启动,并且处于运行中,处于就绪或者错误状态的任务是不会有输出的。
    2. 确保你的消息源(特别是MQTT主题)是否正确。
    3. 检查你的数据源是否有数据在流进。对于Kafka主题,可以去百度消息服务中,查看对应主题的数据流量;对于MQTT主题,可以通过MQTT客户端工具订阅。
    4. 检查你的消息的格式。对于JSON格式的数据源,如果消息不符合JSON格式,数据会被忽略掉;对于CSV格式的数据,如果实际数据的列数少于定义的字段个数,也会被忽略。
    5. 如果你的消息是有时间窗口的,确保数据源进来的消息的时间戳已经跨越了1个窗口的范围。例如,如果你的任务是1分钟的固定窗口,但已经到达的消息还只有20秒的数据,那自然是不会有输出。特别说明,如果你的任务是多并发度的,那么你的消息会分布到多个并发度上,至少需要某个并发度上的消息跨越了一个窗口才有输出。

    数据源修改后,是否需要重启任务?

    需要

    数据目的地修改后,是否需要重启任务?

    根据数据目的地类型不同而不同:

    数据目的地类型 是否需要重启任务
    百度消息服务(Kafka)
    物接入(MQTT)
    时序数据库(TSDB)
    百度对象存储(BOS)
    上一篇
    SQL手册
    下一篇
    轻量流计算Creek