常见问题及解答(FAQ)
更新时间:2020-12-23
排查流式计算任务没有输出的步骤
- 确保你的任务已经启动,并且处于运行中,处于就绪或者错误状态的任务是不会有输出的。
- 确保你的消息源(特别是MQTT主题)是否正确。
- 检查你的数据源是否有数据在流进。对于Kafka主题,可以去百度消息服务中,查看对应主题的数据流量;对于MQTT主题,可以通过MQTT客户端工具订阅。
- 检查你的消息的格式。对于JSON格式的数据源,如果消息不符合JSON格式,数据会被忽略掉;对于CSV格式的数据,如果实际数据的列数少于定义的字段个数,也会被忽略。
- 如果你的消息是有时间窗口的,确保数据源进来的消息的时间戳已经跨越了1个窗口的范围。例如,如果你的任务是1分钟的固定窗口,但已经到达的消息还只有20秒的数据,那自然是不会有输出。特别说明,如果你的任务是多并发度的,那么你的消息会分布到多个并发度上,至少需要某个并发度上的消息跨越了一个窗口才有输出。
数据源修改后,是否需要重启任务?
需要
数据目的地修改后,是否需要重启任务?
根据数据目的地类型不同而不同:
数据目的地类型 | 是否需要重启任务 |
---|---|
百度消息服务(Kafka) | 是 |
物接入(MQTT) | 否 |
时序数据库(TSDB) | 否 |
百度对象存储(BOS) | 否 |