检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
generated.StormTopology类型的对象，和getTopology()方法相同。 应用开发操作步骤 确认Storm组件已经安装，并正常运行。如果业务需要连接其他组件，请同时安装该组件并运行。 将storm-examples导入到IntelliJ IDEA开发环境，请参见导入并配置Storm样例工程。
面，会定时向RM汇报本节点上的资源使用情况和各个Container的运行状态；另一方面，接收并处理来自AM的Container启动/停止等请求。 ApplicationMaster：AM负责一个Application生命周期内的所有工作。包括： 与RM调度器协商以获取资源。 将得
generated.StormTopology类型的对象，和getTopology()方法相同。 应用开发操作步骤 确认Storm组件已经安装，并正常运行。如果业务需要连接其他组件，请同时安装该组件并运行。 将storm-examples导入到Eclipse开发环境，请参见准备Storm应用开发环境。
generated.StormTopology类型的对象，和getTopology()方法相同。 应用开发操作步骤 确认Storm组件已经安装，并正常运行。如果业务需要连接其他组件，请同时安装该组件并运行。 将storm-examples导入到IntelliJ IDEA开发环境，请参见导入并配置Storm样例工程。
--schema 数据库名 例如执行以下命令： hetu-cli --catalog gaussdb_1 --schema admin 执行以下命令，可正常查看数据库表信息或不报错即表示连接成功。 show tables; GAUSSDB数据类型映射 GAUSSDB数据类型（data type）
StructuredStreamingADScalaExample 使用Structured Streaming，从kafka中读取广告请求数据、广告展示数据、广告点击数据，实时获取广告有效展示统计数据和广告有效点击统计数据，将统计结果写入kafka中。 StructuredS
户”必须相同）后，选择“更多 > 批量更新”。 确认并勾选操作影响，配置表2信息后，单击“确定”进行更新。 更新客户端配置期间，客户端不能正常对外提供服务，可能导致使用客户端的业务中断。 表2 更新客户端参数配置 参数名称 取值样例 描述 登录方式 密码 登录方式： 密码：使用密码登录。
件对应一个服务名，提供一种服务。 角色：角色是服务的组成要素，每个服务由一个或多个角色组成，服务通过角色安装到节点（即服务器）上，保证服务正常运行。 实例：当一个服务的角色安装到节点上，即形成一个实例。每个服务有各自对应的角色实例。 各服务的部署原则如MRS集群部署方案说明所示。
/bin/”目录下添加Python软链接，可参考HetuEngine计算实例启动失败报错Python不存在。 HetuEngine服务处于正常运行状态。 创建HetuEngine计算实例步骤 使用hetu_user登录FusionInsight Manager，选择“集群 > 服务
语句，使Loader可通过SQL语句查询结果并作为导入的数据。SQL语句需要有查询条件“WHERE ${CONDITIONS}”，否则无法正常工作。例如，“select * from TABLE WHERE A>B and ${CONDITIONS}”。如果同时配置“表列名”，S
html#rest-api。 准备运行环境 安装客户端。在节点上安装客户端，如安装到“/opt/client”目录。 确认服务端Spark组件已经安装，并正常运行。 客户端运行环境已安装1.7或1.8版本的JDK。 获取并解压缩安装包“MRS_Spark_Client.tar”。执行如下命令解压。
alarm.job.alarm.rocksdb.background.jobs.multiplier 2 flush/compaction的请求量超过了state.backend.rocksdb.thread.num的multiplier倍数，作业将上报告警 在“作业管理”页面单击
huawei.hadoop.hbase.io.crypto.CryptoRuntimeException”异常。此时hbase shell中仍可正常读取该表数据，即加密配置成功。 修改密钥文件 在加密HFile和WAL内容操作中需要生成对应的密钥文件并设置密码，为确保系统安全，在运行一
--schema 数据库名 例如执行以下命令： hetu-cli --catalog oracle_1 --schema oralce 执行以下命令，可正常查看数据库表信息或不报错即表示连接成功。 show tables; Oracle与HetuEngine数据类型映射 数据映射约束： Het
ark Streaming建立于Spark之上，因此其Worker节点也具备了同样的容错能力。然而，由于Spark Streaming的长正常运行需求，其应用程序必须也具备从Driver进程（协调各个Worker的主要应用进程）故障中恢复的能力。使Spark Driver能够容错
范围，则会导致查询冷数据。在这种情况下，查询吞吐量会受到冷存储的限制。 冷存储中的数据常用于归档，会很少访问。如果冷存储中的数据被大量频繁请求访问，请检查冷热数据边界（COLD_BOUNDARY）配置是否正确。如果频繁查询的大量数据在冷存储中将会限制查询的性能。 如果冷存储中存储
约束限制： 不涉及 取值范围： 只能由英文字母、数字以及“_”和“-”组成，且长度为[1-64]个字符。 默认取值： 不涉及 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 service_id 否 String 参数解释： 服务ID，为扩展接口，预留此参数。用户不需要配置。
MRS集群创建失败错误码列表如表6所示。 表6 错误码 错误码 说明 MRS.101 用户请求配额不足，请联系客服提升配额。 MRS.102 用户Token为空或不合法，请稍后重试或联系客服。 MRS.103 用户请求不合法，请稍后重试或联系客服。 MRS.104 用户资源不足，请稍后重试或联系客服。
径的操作权限。 Hive表格式仅支持Parquet、ORC、TextFile。 前提条件 已创建包含Doris服务的集群，集群内各服务运行正常。 待连接Doris数据库的节点与MRS集群网络互通。 创建具有Doris管理权限的用户。 集群已启用Kerberos认证（安全模式） 在FusionInsight
tls.ephemeralDHKeySize=2048 spark.shuffle.servicev2.port Shuffle服务监测数据获取请求的端口。 27338 spark.ssl.historyServer.enabled 配置history server是否使用SSL。 true
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
