检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
的维护集群。当您需要对集群进行巡检时，请通过该功能授权后，联系运维人员进行巡检并获取巡检结果。MRS支持的所有巡检脚本见界面中的巡检脚本列表，MRS目前仅支持证书检测脚本，用来检查集群中的证书是否过期。 开启巡检授权 登录MRS控制台。 单击集群名称进入集群详情页面。 选择“巡检授权”页签。
登录告警节点执行sudo su - root切换用户，执行ntpq -np命令。 如果显示结果的主OMS节点NTP服务IP地址前有“*”号，表示同步正常，如下： remote refid st t when poll reach delay offset jitter ======
在FusionInsight Manager首页，选择“集群 > 待操作集群的名称 > 服务 > Loader > 实例”，单击上报告警实例主机名对应的角色名，单击图表区域右上角的下拉菜单，选择“定制”，勾选“GC”中的“Loader的总GC时间”，单击“确定”。 图1 Loader的总GC时间 查看Loa
properties”的配置是否有误。 是，执行3.e。 否，执行4。 修改“properties.properties”配置文件。 查看告警列表中，该告警是否已清除。 是，处理完毕。 否，执行4。 收集故障信息。 在MRS Manager界面，单击“系统设置 > 日志导出”。 请联系运维人员，并发送已收集的故障日志信息。
authentication.type 登录认证的方式。 “kerberos”，表示使用安全模式，进行Kerberos认证。Kerberos认证提供两种认证方式：密码和keytab文件。 “simple”，表示使用普通模式，不进行Kerberos认证。 kerberos authentication
authentication.type 登录认证的方式。 “kerberos”，表示使用安全模式，进行Kerberos认证。Kerberos认证提供两种认证方式：密码和keytab文件。 “simple”，表示使用普通模式，不进行Kerberos认证。 kerberos authentication
图1 reimport projects 编译运行程序。 放置好配置文件，并修改代码匹配登录用户后，文件列表如图2所示。 图2 hbase-example待编译目录列表 编译方式有以下两种。 方法一 选择“Maven > 样例工程名称 > Lifecycle > clean”，
> Impalad Web UI”，单击任一个节点进入Web UI页面。 在Web UI页面，单击“/backends”，查看Impala列表，找到告警上报的实例，单击“Web UI”，进入亚健康节点的Web UI后，单击“/queries”，查看任务执行情况，是否存在执行缓慢的任务。
默认取值： 不涉及 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 cluster_name 是 String 参数解释： 新的集群名称。 约束限制： 不涉及 取值范围： 不涉及 默认取值： 不涉及 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型
、不可变的消息序列，并不断追加到提交日志文件。分区的消息每个也被赋值一个称为偏移顺序（Offset）的序列化编号。 图1 Kafka结构 表1 Kafka结构图说明 名称 说明 Broker 在Kafka集群上一个服务器称为一个Broker。 Topic/主题 一个Topic就是
造成服务数据无法写入，业务系统运行不正常。 可能原因 硬盘被拔出。 硬盘离线、硬盘坏道等故障。 处理步骤 登录MRS集群详情页面，选择“告警管理”。 在实时告警列表中，单击此告警所在行。 在“告警详情”区域，从“定位信息”中获取“HostName”、“PartitionName”和“DirName”。
r节点和备集群RegionServer所在主机的网络连接是否正常。 是，执行5 否，执行3 联系网络管理员恢复网络。 网络恢复后，在告警列表中，查看本告警是否清除。 是，处理完毕。 否，执行5。 检查主集群RegionServer的Region分布情况 在FusionInsight
eeper配置文件“zoo.cfg”中的“syncLimit”和“initLimit”两参数值，直到ZooKeeperServer正常。 表1 参数说明 参数 描述 默认值 syncLimit follower与leader进行同步的时间间隔（时长为ticket时长的倍数）。如果
上报告警的ClickHouseServer实例IP --user 用户名 --password --port 9440 执行以下语句，查询系统表判断是否有业务频繁写入，若有相关业务，等待业务执行完成，查看告警是否清除。 SELECT query_id, user, FQDN(), elapsed
处理步骤 检查是否Level0层SST文件数太多 在FusionInsight Manager首页，选择“运维 > 告警 > 告警”。 在告警列表中，查看是否存在告警“ALM-45644 RocksDB的Level0层SST文件数持续超过阈值”。 是，执行3。 否，执行5。 参考ALM-45644
MapReduce统计样例代码 功能介绍 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 主要分为三个部分： 从原文件中筛选女性网民上网时间数据信息，通过类CollectionMapper继承Mapper抽象类实现。 汇总每个女性上网时间，并输出时间大于两个小时的
Spark DAG设计规范说明 操作场景 合理的设计程序结构，可以优化执行效率。在程序编写过程中要尽量减少shuffle操作，合并窄依赖操作。 操作步骤 以“同行车判断”例子讲解DAG设计的思路。 数据格式：通过收费站时间、车牌号、收费站编号...... 逻辑：以下两种情况下判定这两辆车是同行车：
选择“集群 > 待操作集群的名称 > 服务 > IoTDB > 实例”，单击告警上报的IoTDBServer，进入实例“概览”页面。单击图表区域右上角的下拉菜单，选择“定制 > 内存”，勾选“IoTDBServer堆内存使用率”，单击“确定”，查看IoTDBServer进程使用的
Spark DAG设计规范说明 操作场景 合理的设计程序结构，可以优化执行效率。在程序编写过程中要尽量减少shuffle操作，合并窄依赖操作。 操作步骤 以“同行车判断”例子讲解DAG设计的思路。 数据格式：通过收费站时间、车牌号、收费站编号...... 逻辑：以下两种情况下判定这两辆车是同行车：
Flink Job Pipeline增强 通常情况下，开发者会将与某一方面业务相关的逻辑代码放在一个比较大的Jar包中，这种Jar包称为Fat Jar。 Fat Jar具有以下缺点： 随着业务逻辑越来越复杂，Jar包的大小也不断增加。 协调难度增大，所有的业务开发人员都在同一套业
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
