检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
根据需求动态启动，可避免浪费资源。 实现方案 多租户模式的HA方案原理如图1所示。 图1 Spark JDBCServer多租户 ProxyServer在启动时，向ZooKeeper注册自身消息，在指定目录中写入节点信息，节点信息包含了该实例对应的IP，端口，版本号和序列号等信息（多节点信息之间以逗号隔开）。
无 数据处理规则 按顺序将“被拼接字段名”中配置的字段的值，通过连接符拼接后，赋给“输出字段名”。 当有字段的值为null时，会转化为空字符串，再与其它字段值拼接。 样例 通过“CSV文件输入”算子，生成三个字段A、B和C。 源文件如下图： 配置“拼接转换”算子，“分隔符”为空格，生成新字段D：
0及之后版本的Manager界面中，“集群 > 概览”页面已移除，可直接在“主页”界面的“更多”菜单中执行集群相关维护管理功能。 选择“更多 > 重启配置过期的实例”。 在弹出窗口中输入当前登录的用户密码确认身份，然后单击“确定”。 在确认重启实例的对话框中单击“确定”。 支持单击“查
FS目录。不支持填写HDFS中的隐藏目录，例如快照或回收站目录；也不支持默认的系统目录，例如“/hbase”或“/user/hbase/backup”。 “最大备份数”：填写备份目录中可保留的备份文件集数量。 OBS 表示将备份文件保存在OBS目录中，仅MRS 3.3.0-LTS及之后版本支持。
source算子的代码，该段代码每发送10000条数据休息1秒钟，制作快照时将到目前为止已经发送的数据的条数保存在UDFState中；从快照中状态恢复时，读取UDFState中的数据条数并重新赋值给count变量。 1 2 3 4 5 6 7 8 9 10 11 12 13 14
单击作业“Logs”列的“Logs”，查看并保存Jobmanager日志。 图2 单击“Logs” 单击“Attempt ID”列的ID，单击“Logs”列的“Logs”，查看并保存Taskmanager日志，执行14。 图3 单击“Attempt ID”列的ID 图4 单击“Logs” 使用具有当前Flink
单击作业“Logs”列的“Logs”，查看并保存Jobmanager日志。 图2 单击“Logs” 单击“Attempt ID”列的ID，单击“Logs”列的“Logs”，查看并保存Taskmanager日志。 图3 单击“Attempt ID”列的ID 图4 单击“Logs” 使用具有当前Flink作业的
已经配置完成导入并配置Oozie样例工程的前提条件。 开发环境配置 参考获取MRS应用开发样例工程，获取样例代码解压目录中“src\oozie-examples”目录下的样例工程文件夹“ooziesecurity-examples”中的OozieSparkHBaseExample和OozieSparkHiveExample样例工程。
知进程健康状态。 硬盘故障的自动处理 MRS对开源版本进行了增强，可以监控各节点上的硬盘以及文件系统状态。如果出现异常，立即将相关分区移出存储池；如果硬盘恢复正常（通常是因为用户更换了新硬盘），也会将新硬盘重新加入业务运作。这样极大简化了维护人员的工作，更换故障硬盘可以在线完成；
解决操作系统日志转储配置问题。 补丁兼容关系 包含1.7.1.5及之前发布的所有补丁解决的问题。 注意事项 由于1.7.1 集群的健康检查中存在一项误报，而补丁安装前会进行集群的健康检查。从而导致客户第一次提交安装补丁后，提示集群异常，补丁安装终止。在确认报错是误报后，客户可以再
通过Hue管理Oozie作业 操作场景 用户需要使用图形化界面查看集群中所有作业时，可以通过Hue完成任务。 Hue提供了Oozie作业管理器功能，使用户可以通过界面图形化的方式使用Oozie。 Hue界面主要用于文件、表等数据的查看与分析，禁止通过Hue界面对操作对象进行删除等
单击作业“Logs”列的“Logs”，查看并保存Jobmanager日志。 图2 单击“Logs” 单击“Attempt ID”列的ID，单击“Logs”列的“Logs”，查看并保存Taskmanager日志，执行11。 图3 单击“Attempt ID”列的ID 图4 单击“Logs” 使用具有当前Flink
集群处于以下状态时无法访问FusionInsight Manager： 启动中、停止中、停止、删除中、已删除、冻结。 通过弹性IP访问FusionInsight Manager 登录MRS管理控制台页面。 单击“现有集群”，在集群列表中单击指定的集群名称，进入集群信息页面。 单击“集群管理页面 ”后的“前往
无 数据处理规则 按顺序将“被拼接字段名”中配置的字段的值，通过连接符拼接后，赋给“输出字段名”。 当有字段的值为null时，会转化为空字符串，再与其他字段值拼接。 样例 通过“CSV文件输入”算子，生成三个字段A、B和C。 源文件如下图： 配置“拼接转换”算子，“分隔符”为空格，生成新字段D：
调测Kafka High level Streams样例程序 在Windows中调测程序 在Windows环境调测程序步骤请参考在Windows中调测程序。 在Linux环境调测程序 编译并生成Jar包，并将Jar包复制到与依赖库文件夹同级的目录“src/main/resourc
Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入FusionInsight的kafka-clients-*.ja
实际使用时长计费，集群后续费用不再收取该节点费用。 到期后影响 图1描述了包年/包月MRS集群资源各个阶段的状态。购买后，在计费周期内资源正常运行，此阶段为有效期；资源到期而未续费时，将陆续进入宽限期和保留期。 图1 包年/包月MRS资源生命周期 到期预警 包年/包月MRS集群资
的下拉菜单，在定位信息中确认告警上报的主机名所在的节点IP地址。 在FusionInsight Manager首页，选择“集群 > 待操作集群的名称 > 服务 > ZooKeeper > 实例”，单击对应IP地址的“角色”列的“quorumpeer”。单击图表区域右上角的下拉菜单，选择“定制
告警上报的Catalog实例 > 图表 > 进程FGCT ”，查看FGC时间是否大于步骤1中的阈值。 是，执行4。 否，执行5。 通过“运维> 告警 > 阈值设置 > 待操作集群的名称 > Impala>进程FGCT->Catalog进程FGCT（Catalog）”修改阈值大小，使其小于3中的时间，查看告警是否清除。
出现此告警时，说明当前Doris实例设置的堆内存无法满足当前数据传输所需的堆内存，建议打开实例监控界面，在页面上查看“Doris堆内存资源状况”监控图表，观察该监控图表中“Doris使用的堆内存大小”的变化趋势，根据当前堆内存使用的大小，调整“-Xmx”的值为当前堆内存使用量的两倍（或根据实际情况进行调整）。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
