检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
interval”设置成较大的值，或者不对参数进行设置。查看MapReduce任务是否能成功执行。 是，执行2.e。 否，执行2.b。 检查Yarn服务状态。 登录MRS集群详情页面，选择“告警管理”。 在告警列表中，查看是否有“ALM-18000 Yarn服务不可用”产生。 是，执行2
story部分数据丢失。 查看调测结果 Spark应用程序运行完成后，可通过如下方式查看应用程序的运行情况。 通过运行结果数据查看应用程序运行情况。 结果数据存储路径和格式已经由Spark应用程序指定，可通过指定文件获取。 登录Spark WebUI查看应用程序运行情况。 Spark主要有两个Web页面。
在告警列表中单击该告警所在行的，从“定位信息”处获得任务名。 选择“运维 > 备份恢复 > 恢复管理”。 根据“任务名”查找对应恢复任务，查看恢复任务的详细信息。 启动该恢复任务，查看恢复任务是否执行成功。 是，执行8。 否，执行9。 等待2分钟，检查告警是否消除。 是，结束操作。 否，执行9。
开发Flink应用 编译并运行程序 指导用户将开发好的程序编译并提交运行。 编译并调测Flink应用 查看程序运行结果 程序运行结果会写在用户指定的路径下，用户还可以通过UI查看应用运行情况。 查看Flink应用调测结果 调优程序 您可以根据程序运行情况，对程序进行调优，使其性能满足业务场景需求。
DataStream应用开发思路 编译并运行程序 指导用户将开发好的程序编译并提交运行。 编译并运行Flink应用 查看程序运行结果 程序运行结果会写在用户指定的路径下，用户还可以通过UI查看应用运行情况。 查看Flink应用运行结果 调优程序 您可以根据程序运行情况，对程序进行调优，使其性能满足业务场景需求。
开发Flink应用 编译并运行程序 指导用户将开发好的程序编译并提交运行。 编译并调测Flink应用 查看程序运行结果 程序运行结果会写在用户指定的路径下，用户还可以通过UI查看应用运行情况。 查看Flink应用调测结果 调优程序 您可以根据程序运行情况，对程序进行调优，使其性能满足业务场景需求。
待操作集群的名称 > 服务 > DBService”。 在“概览”页面查看“数据目录磁盘空间使用率”图表，检查数据目录磁盘空间使用率是否超过90%。 是，执行3。 否，执行13。 以omm用户登录DBServer主管理节点，执行以下命令，查看数据库是否进入只读模式。 source $DBSERVER_HOME/
告警”，在告警列表中查看对应的磁盘是否存在“ALM-12017 磁盘容量不足”告警。 是，执行4。 否，执行5。 参考ALM-12017 磁盘容量不足操作步骤进行处理，故障恢复后，查看本告警是否恢复。 是，处理完毕。 否，执行7。 选择“主机 > 待查看的主机名称”，在主机的概览页面查看对应分
告警阈值配置不合理。 租户分配的文件目录数上限不合理 处理步骤 查看阈值设置是否合理 查看告警定位信息，获取上报告警的租户名称，租户目录。 在FusiongInsight Manager首页，单击“租户资源”页面选择上报告警的租户名称，单击“资源”，查看上报告警的租户目录所对应的文件数阈值配置设置是
急”或“重要”告警级别对应的“阈值”为告警出现后1天内监控值的峰值的150%，单击“确定”保存。 等待5分钟，查看该告警是否自动清除。 是，处理完毕。 否，执行6。 查看Guardian TokenServer内存设置是否过小。 在FusionInsight Manager首页，选择“运维
检查Flink依赖的ZooKeeper服务是否异常。 在FusionInsight Manager首页，选择“运维 > 告警 > 告警”。 在告警列表中，查看是否存在告警“ALM-13000 ZooKeeper服务不可用”。 是，执行3。 否，执行5。 参考ALM-13000 ZooKeeper服务不可用章节处理对应的告警。
ource.jar。 打包Strom应用业务 提交拓扑 指导用户将开发好的程序提交运行。 提交Storm拓扑 查看程序运行结果 指导用户提交拓扑后查看程序运行结果。 查看Storm应用调测结果 父主题： Storm应用开发概述
调整Spark日志级别 配置场景 在某些场景下，当任务已经启动后，用户想要修改日志级别以定位问题或者查看想要的信息。 用户可以在进程启动前，在进程的JVM参数中增加参数“-Dlog4j.configuration.watch=true”来打开动态设置日志级别的功能。进程启动后，就
确保本地环境的时间与MRS集群的时间差要小于5分钟，若无法确定，请联系系统管理员。MRS集群的时间可通过FusionInsight Manager页面右下角查看。 已准备开发环境及MRS集群相关配置文件，详情请参考准备连接Kafka集群配置文件。 操作步骤 获取样例工程文件夹。 参考获取MRS应用
调整Spark日志级别 配置场景 在某些场景下，当任务已经启动后，用户想要修改日志级别以定位问题或者查看想要的信息。 用户可以在进程启动前，在进程的JVM参数中增加参数“-Dlog4j.configuration.watch=true”来打开动态设置日志级别的功能。进程启动后，就
的补丁，单击“卸载”，等待补丁卸载成功后，需要按照该章节顺序依次执行相关操作。 当“状态”显示为“卸载失败”时，在“失败任务”中查看错误提示信息，查找相应日志来定位处理。 如果任务失败，选择“重试卸载”，只有当“状态”显示为“可用”时，才能进入下一步操作。 卸载失败或者重试后仍然
的补丁，单击“卸载”，等待补丁卸载成功后，需要按照该章节顺序依次执行相关操作。 当“状态”显示为“卸载失败”时，在“失败任务”中查看错误提示信息，查找相应日志来定位处理。 如果任务失败，选择“重试卸载”，只有当“状态”显示为“可用”时，才能进入下一步操作。 卸载失败或者重试后仍然
在告警详情页面单击“清除告警”，并继续观察该告警，查看同一块磁盘的告警是否会继续上报。 如果当前磁盘出现三次以上该告警，建议用户更换磁盘。 是，执行17。 否，操作结束。 更换磁盘。 在MRS Manager界面，单击“告警管理”。 查看该告警的详细信息，查看定位信息中对应的“主机名”字段和“磁
式删除某些列如“col1”后，更新parquet文件中以旧的schema写入的列“col1”，在这种情况下，parquet尝试在传入记录中查找所有当前字段，当发现“col1”不存在时，发生上述异常。 解决这个问题的办法是使用所有schema演进版本来创建uber schema，并使用该schema作为target
story部分数据丢失。 查看调测结果 Spark应用程序运行完成后，可通过如下方式查看应用程序的运行情况。 通过运行结果数据查看应用程序运行情况。 结果数据存储路径和格式已经由Spark应用程序指定，可通过指定文件获取。 登录Spark WebUI查看应用程序运行情况。 Spark主要有两个Web页面。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
