所有文档

          规则引擎 Rule Engine

          常见问题及解答(FAQ)

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

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

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

          需要

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

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

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