检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
前提条件 系统管理员已明确业务需求，并准备一个Kafka管理员用户（属于kafkaadmin组）。 已安装Kafka客户端。 操作步骤 以客户端安装用户，登录安装Kafka客户端的节点。 切换到Kafka客户端安装目录，例如“/opt/kafkaclient”。
RetryingBlockFetcher.java:170) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run
以root用户登录HDFS客户端，用户密码为安装前用户自定义，请咨询系统管理员。执行cd命令进入客户端安装目录，然后执行source bigdata_env。 如果集群采用安全版本，要进行安全认证。 执行kinit hdfs命令，按提示输入密码。向MRS集群管理员获取密码。
JobManager Flink系统的管理节点，管理所有的TaskManager，并决策用户任务在哪些Taskmanager执行。JobManager在HA模式下可以有多个，但只有一个主JobManager。 Flink系统提供的关键能力： 低时延 提供ms级时延的处理能力。
（普通模式集群跳过此步骤） 在FusionInsight Manager管理界面，选择“集群 > 待操作集群的名称 > 服务 > KrbServer”。 查看KrbServer服务的运行状态是否为“良好”。 是，执行5。 否，执行3。
图3 单击“Attempt ID”列的ID 图4 单击“Logs” 使用具有当前Flink作业的管理操作权限的用户登录Manager，选择“集群 > 服务 > Flink”，单击“Flink WebUI”后的链接，单击“作业管理”，在作业的“操作”列选择“更多 > 作业详情”也可查看
图3 单击“Attempt ID”列的ID 图4 单击“Logs” 使用具有当前Flink作业的管理操作权限的用户登录Manager，选择“集群 > 服务 > Flink”，单击“Flink WebUI”后的链接，单击“作业管理”，在作业的“操作”列选择“更多 > 作业详情”也可查看
选择“系统设置 > 用户组管理 > 添加用户组”，为样例工程创建一个用户组，例如flinkgroup。选择“系统设置 > 用户管理 > 添加用户”，为样例工程创建一个用户。
检查所有节点管理平面网络是否互通 登录FusionInsight Manager界面，选择“运维 > 告警 > 告警”。 查看当前集群是否存在“ALM-12089 节点间网络互通异常”或“节点故障”等告警。 是，节点间网络不互通，请联系运维人员修复。
在运维管理或应用开发的场景中，需要在客户端认证用户身份后才能连接到集群服务端。系统操作运维与业务场景中主要使用的用户分为“人机”用户和“机机”用户。二者主要区别在于“机机”用户密码由系统随机生成。
以root用户登录HDFS客户端，用户密码为安装前用户自定义，请咨询系统管理员。执行cd命令进入客户端安装目录，然后执行source bigdata_env。 如果集群采用安全版本，要进行安全认证。 执行kinit hdfs命令，按提示输入密码。向MRS集群管理员获取密码。
进入该逻辑集群页面，选择“查询管理 > 已经结束的查询”页签。 界面的参数说明参考表1，过滤条件说明参考表2说明。 父主题： ClickHouse企业级能力增强
单击“集群管理页面”后面的“前往 Manager”，弹出“访问MRS Manager页面”。 单击“管理安全组规则”，检查安全组规则配置。 检查入口方向Any协议的源地址是否为0.0.0.0/0。 如果是，修改入口方向Any协议的远端为指定IP地址。如果不是，则无需修改。
value " + i); } session.apply(insert); } // Call session.close() to end the session and ensure the rows are // flushed and errors are returned
value " + i); } session.apply(insert); } // Call session.close() to end the session and ensure the rows are // flushed and errors are returned
以root用户登录该告警的主机地址，用户密码为安装前用户自定义，请咨询系统管理员。
if(args.length <1){ System.out.println("JavaHBaseMapPartitionExample {tableName} is missing an argument"); return
单击“组件管理”观察各个组件是否存在异常，若存在异常等待5~10分钟后再次观察组件，依然存在异常则联系华为云技术支持处理。 单击“告警管理”观察是否存在异常告警，若存在请清除告警后再进行其他操作。 父主题： MRS集群容量调整
基于Guardian存算分离管理面作业提交依赖JobGateway模式，不支持Executor模式。 使用存算分离集群。 在具备OBS资源的访问权限后，MRS集群内相关组件可通过客户端访问对应文件资源。
以root用户登录到产生告警的DataNode的节点，用户密码为安装前用户自定义，请咨询系统管理员。 如果告警原因为“DataNode数据目录创建失败”，执行10。 如果告警原因为“DataNode数据目录与系统关键目录（/或/boot）使用同一磁盘”，执行17。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
