检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
回滚补丁 回滚补丁前检查 回滚补丁 回滚补丁后操作 父主题： MRS 3.2.0-LTS.1.8补丁说明
ParameterTool paraTool = ParameterTool.fromArgs(args); // 构造流图，将自定义Source生成的数据写入Kafka DataStream<String> messageStream = env.addSource(new
wkey对应的数据信息，并进行简单的操作。 打包项目 通过IDEA自带的Maven工具，打包项目，生成jar包。具体操作请参考在Linux环境中编包并运行Spark程序。 将打包生成的jar包上传到Spark客户端所在服务器的任意目录（例如“$SPARK_HOME” ）下。 若运行“Spark
安装补丁前准备 安装补丁前需要手动进行以下相关检查。 检查所有节点管理平面网络是否互通 登录FusionInsight Manager界面，选择“运维 > 告警 > 告警”。 查看当前集群是否存在“ALM-12089 节点间网络互通异常”或“节点故障”等告警。 是，节点间网络不互通，请联系运维人员修复。
IAM用户同步是指将绑定MRS相关策略的IAM用户同步至MRS系统中，创建同用户名、不同密码的账号，用于集群管理。同步之后，用户可以使用IAM用户名（密码需要Manager的管理员admin重置后方可使用）登录Manager管理集群。也可以在开启Kerberos认证的集群中，通过界面方式提交作业。 IAM用
Master节点规格升级前准备 登录MRS管理控制台。 选择 “现有集群” ，选中需要升级Master节点规格的集群并单击集群名，进入集群信息页面。 查看集群状态，确保集群状态为“运行中”。 在“节点管理”页签查看各节点状态，确保集群所有节点的状态为“运行中”。 登录Manager，进入集群管理页面，具体请参见访问MRS集群Manager。
手动注册的客户端信息也可以手动进行修改或者删除。 在“客户端管理”界面选择待操作的客户端，单击“导出全部”可导出所有已注册的客户端信息到本地。 客户端管理界面上组件列表栏只展示有真实客户端的组件，因此部分没有客户端的组件和客户端特殊的组件不会显示在组件列表栏。 父主题： 管理MRS集群客户端
块信息。 如果有丢块，WebUI上会有一行红字显示。 admin用户默认不具备其他组件的管理权限，如果访问组件原生界面时出现因权限不足而打不开页面或内容显示不全时，可手动创建具备对应组件管理权限的用户进行登录。 用户确认丢失块所在的文件是否有用。 MapReduce任务运行过程中
ParameterTool paraTool = ParameterTool.fromArgs(args); // 构造流图，将自定义Source生成的数据写入Kafka DataStream<String> messageStream = env.addSource(new
sparktest; select * from sparktest02; 出现以上结果表示，动态脱敏配置已生效，登录ranger脱敏策略管理界面可以看到有自动生成的表sparktest02的脱敏策略。 父主题： Spark Core企业级能力增强
管理Kafka Topic中的消息 操作场景 用户可以根据业务需要，使用MRS集群客户端，在Kafka主题中产生消息，或消费消息。 前提条件 已安装集群客户端。 启用Kerberos认证的集群，需要提前在Manager中创建业务用户，用户拥有在Kafka主题中执行相应操作的权限。
“确定”完成解锁操作。 MRS 2.x及之前版本： 在MRS Manager，单击“系统设置”。 在“权限配置”区域，单击“用户管理”。 图1 用户管理 在要解锁用户所在行，选择“解锁用户”。 图2 解锁用户 在弹出的提示窗口，单击“确定”完成解锁操作。 解锁系统内部用户 该操作仅适用于MRS
配置Doris表的列权限管理 操作场景 在FE的自定义配置项中添加“enable_col_auth”参数开启列授权后，Doris支持对列级别权限的管理。 该特性仅MRS 3.3.1及之后版本支持。 表的列级别的授权仅支持Select_priv权限。 必须使用具有Grant_priv权限的用户进行列权限的管理操作。
补丁安装后操作 重新打开弹性伸缩 升级完补丁后需要重新打开弹性伸缩，操作如下： 登录华为云管理控制台，在“现有集群”列表中选择对应集群，单击“弹性伸缩”。 开启安装前关闭的弹性策略。 父主题： MRS 3.1.0 运维通道补丁说明
的链接访问开源WebUI。 对于开启Kerberos认证的集群，admin用户不具备各组件的管理权限，如需正常访问各组件的Web UI界面，请提前参考创建MRS集群用户创建具有对应组件管理权限的用户。 操作视频 本视频为您介绍如何为MRS集群绑定弹性公网IP，并访问集群中组件的WebUI页面。
opic的offset变小，则会将Kafka上topic最新的offset作为读取Kafka数据的起始位置，继续读取后续的数据。 对于已经生成但未调度处理的任务，若读取的Kafka offset区间大于Kafka上topic的最新offset，则该任务会运行失败。 若任务失败过多
val paraTool = ParameterTool.fromArgs(args) // 构造流图，将自定义Source生成的数据写入Kafka val messageStream: DataStream[String] = env.addSource(new
81。 JAR_PATH为程序jar包所在路径。 brokerlist格式为brokerIp:9092。 开发思路 接收Kafka中数据，生成相应DStream。 筛选数据信息并分析。 找到对应的HBase表记录。 计算结果，写到HBase表。 父主题： Streaming从Kafka读取数据再写入HBase
已安装客户端，具体请参考安装客户端章节。例如安装目录为“/opt/hadoopclient”，以下操作的客户端目录只是举例，请根据实际安装目录修改。 各组件业务用户由MRS集群管理员根据业务需要创建。安全模式下，“机机”用户需要下载keytab文件。“人机”用户第一次登录时需修改密码。 使用Hive客户端 以客户端安装用户，登录安装客户端的节点。
完成。 在“作业管理”的作业列表中，找到创建的作业名称，单击操作列的“启动”，等待作业启动。 观察数据传输是否生效，例如在PgSQL数据库中对表进行插入数据操作，然后参考查看Kafka数据生产消费详情进入KafkaUI界面查看Kafka的Topic中是否有数据生成。 父主题： 使用CDL
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
