1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答- 场景描述上线运行作业后，下游结果表中没有数据。
- 排错流程图
- 检查作业中是否存在Failover
- 排错指引查看Failover报错信息，分析作业运行异常原因。
- 解决方案解决Failover问题，使作业正常运行。
- 检查源表数据是否进入实时计算Flink版
- 排错指引这种情况下没有Failover，但数据延时会很大，查看数据曲线页面numRecordsIn_VVP，检查各Source输入是否有数据。
- 解决方案检查源表，保证上游有数据进入实时计算Flink版。
- 检查数据是否被某个节点过滤在作业运维页面，单击目标作业名称，单击返回开发，在页面右侧高级配置面板的更多Flink配置中添加pipeline.operator-chaining: 'false' ，将节点拆分，然后观察每个节点的Bytes Received（输入）和Bytes Sent（输出），确定数据在哪个节点被过滤，如果某个节点输出为0，输入不为0，说明数据被这个节点过滤了。常见的导致数据无输出的算子包括join、window或where。
- 检查下游是否由于默认缓存机制缓存了数据
- 解决方案：排除作业的业务逻辑异常后，调整下游存储的batchsize的大小。
- 检查作业是否存在严重业务延迟
- 解决方案：检查作业是否反压节点调整并发处理能力等待任务无延迟后检查数据。
重要：如果batchsize参数设置的过小，则可能会造成下游数据库I/O压力过大、存在性能瓶颈的风险。例如，如果将batchsize设置为1，说明处理完一条数据，就会请求一次数据库，大数据场景下会导致数据库压力大。- 检查下游RDS，是否存在死锁
- 解决方案：参见上下游存储。
2024-06-01 10:02:16赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
