罗盘
罗盘是一个大数据任务诊断平台,旨在提升用户排查问题效率,降低用户异常任务成本。
其主要功能特性如下:
- 非侵入式,即时诊断,无需修改已有的调度平台,即可体验诊断效果。
- 支持多种主流调度平台,例如DolphinScheduler、Airflow或自研等。
- 支持多版本Spark、Hadoop 2.x和3.x 任务日志诊断和解析。
- 支持工作流层异常诊断,识别各种失败和基线耗时异常问题。
- 支持引擎层异常诊断,包含数据倾斜、大表扫描、内存浪费等14种异常类型。
- 支持各种日志匹配规则编写和异常阈值调整,可自行根据实际场景优化。
罗盘已支持诊断类型概览:
        诊断维度
        诊断类型
        类型说明
        失败分析
        运行失败
        最终运行失败的任务
        首次失败
        重试次数大于1的成功任务
        长期失败
        最近10天运行失败的任务
        耗时分析
        基线时间异常
        相对于历史正常结束时间,提前结束或晚点结束的任务
        基线耗时异常
        相对于历史正常运行时长,运行时间过长或过短的任务
        运行耗时长
        运行时间超过2小时的任务
        报错分析
        sql失败
        因sql执行问题而导致失败的任务
        shuffle失败
        因shuffle执行问题而导致失败的任务
        内存溢出
        因内存溢出问题而导致失败的任务
        成本分析
        内存浪费
        内存使用峰值与总内存占比过低的任务
        CPU浪费
        driver/executor计算时间与总CPU计算时间占比过低的任务
        效率分析
        大表扫描
        没有限制分区导致扫描行数过多的任务
        OOM预警
        广播表的累计内存与driver或executor任意一个内存占比过高的任务
        数据倾斜
        stage中存在task处理的最大数据量远大于中位数的任务
        Job耗时异常
        job空闲时间与job运行时间占比过高的任务
        Stage耗时异常
        stage空闲时间与stage运行时间占比过高的任务
        Task长尾
        stage中存在task最大运行耗时远大于中位数的任务
        HDFS卡顿
        stage中存在task处理速率过慢的任务
        推测执行Task过多
        stage中频繁出现task推测执行的任务
        全局排序异常
        全局排序导致运行耗时过长的任务
如何使用
1. 代码编译
cd compass
mvn package -DskipTests
2. 配置修改
vim bin/compass_env.sh
# Scheduler MySQL
export SCHEDULER_MYSQL_ADDRESS=“ip:port”
export SCHEDULER_MYSQL_DB=“scheduler”
export SCHEDULER_DATASOURCE_USERNAME=“user”
export SCHEDULER_DATASOURCE_PASSWORD=“pwd”
# Compass MySQL
export COMPASS_MYSQL_ADDRESS=“ip:port”
export COMPASS_MYSQL_DB=“compass”
export SPRING_DATASOURCE_USERNAME=“user”
export SPRING_DATASOURCE_PASSWORD=“pwd”
# Kafka
export SPRING_KAFKA_BOOTSTRAPSERVERS=“ip1:port,ip2:port”
# Redis
export SPRING_REDIS_CLUSTER_NODES=“ip1:port,ip2:port”
# Zookeeper
export SPRING_ZOOKEEPER_NODES=“ip1:port,ip2:port”
# Elasticsearch
export SPRING_ELASTICSEARCH_NODES=“ip1:port,ip2:port”
3. 一键部署
文档
系统截图







版权
罗盘许可证是 Apache License, Version 2.0,详情请参考 LICENSE
and NOTICE 。
 
                            