检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
getAbsolutePath() + ") is not a file."); } // 3.设置并检查krb5config setKrb5Config(krb5ConfFile.getAbsolutePath());
pplicationMaster使用该协议要求NodeManager启动/中止Container或者查询Container的运行状态。 表3 ContainerManagementProtocol常用方法 方法 说明 getContainerStatuses(GetContainerStatusesRequest
sessionPool = new IoTDBSessionPool("127.0.0.1", 22260, "认证用户名", "认证用户密码", 3); // start consumer thread KafkaConsumerMultThread consumerThread
定义startaction 请参见Start Action 2 定义MapReduceaction 请参见MapReduce Action 3 定义FS action 请参见FS Action 4 定义end action 请参见End Action 5 定义killaction 请参见Kill
--create --zookeeper {zkQuorum}/kafka --replication-factor 1 --partitions 3 --topic {Topic} 启动Kafka的Producer，向Kafka发送数据。 java -cp {ClassPath} com
pplicationMaster使用该协议要求NodeManager启动/中止Container或者查询Container的运行状态。 表3 ContainerManagementProtocol常用方法 方法 说明 getContainerStatuses(GetContainerStatusesRequest
Server的会话过程中定义使用。 在Hive Server中使用该函数，执行SQL语句。 SELECT addDoubles(1,2,3); 若重新连接客户端再使用函数出现[Error 10011]的错误，可执行reload function;命令后再使用该函数。 在Hive
examples.WriteIntoKafka和com.huawei.flink.example.kafka.ReadFromKafka 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
final String brokers = args[2]; final String zkQuorum = args[3]; Duration batchDuration = Durations.seconds(5); SparkConf sparkConf
${SPARK_HOME}/examples/jars/spark-examples_2.11-2.3.2-mrs-2.0.jar 6 3000 3000 3 spark-sql 启动一个Spark应用，执行Spark SQL。可以指定local(--master local)或是集群模式(--master
约束限制： 不涉及 取值范围： true：扩容后不启动组件。 false：扩容后启动组件。 默认取值： false 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 result String 参数解释： 请求操作结果，succeeded为操作成功，failed为
internal.truststore: /opt/client/Flink/flink/conf/flink.truststore 针对MRS3.x及之后版本，操作如下： 方法1： 关闭Flink SSL通信加密，修改客户端配置文件“conf/flink-conf.yaml”。 security
A0."TABLE_NAME" = '$1' ANDA0.DB_NAME = '$2' AND A0.PARTITION_NAME = '$3' AND((((((A0."COLUMN_NAME" = '$4') OR (A0."COLUMN_NAME" ='$5')) OR (A0
用户需要在HBase中对指定的数据库或表设置权限，才能够创建表、查询数据、删除数据、插入数据、更新数据以及授权他人访问HBase表。 本章节适用于MRS 3.x及之后版本。 仅开启了Kerberos认证的集群（安全模式）支持创建HBase角色。 如果当前组件使用了Ranger进行权限控制，须基于
Select Group：testuser Select User：testuser Permissions：Create和select 图3 新增hivedev的访问控制策略 单击“Add”，完成策略添加，依据如上Policy示例，testuser用户组中的testuser用户将
服务配置”，将“基础配置”切换为“全部配置”。 搜索并修改“hbase.security.authorization”为“true”（选择第一个HBase下的参数即可）。 图3 修改hbase.security.authorization 搜索“hbase.coprocessor.master.classes”，并在原值后追加“
查看集群健康检查报告”。 在健康检查的报告面板上单击“导出报告”导出健康检查报告，可查看检查项的完整信息。 在Manager查看健康检查报告（MRS 3.x及之后版本） 登录MRS集群Manager界面。 登录集群Manager界面请参考访问MRS集群Manager。 选择“运维 > 健康检查”。
ager。 选择“租户资源”。 MRS 2.x及之前版本选择“租户管理”。 选择“资源池 > 添加资源池”。 设置资源池的属性。 MRS 3.x及之后版本： 图1 添加资源 “集群”：选择待添加资源池的集群名称。 “名称”：填写资源池的名称。可包含数字、字母或下划线（_），且不能以下划线（_）开头。
控指标结果，包含监控指标如下： 服务总体CPU使用率 服务总体磁盘IO读速率 服务总体磁盘IO写速率 服务总体内存使用大小 查看静态资源（3.x及之后版本） 登录MRS集群Manager界面。 登录集群Manager界面请参考访问MRS集群Manager。 选择“集群 > 静态服务池”。
单击“通信安全授权”右侧的开关关闭授权，在弹出窗口单击“确定”。 关闭授权后将导致集群状态变更为“网络通道未授权”，集群部分功能不可用，请谨慎操作。 图3 关闭通信安全授权 若用户已开启敏感操作保护（详见IAM服务的敏感操作），则输入选择的对应验证方式获取的验证码进行进行验证，避免误操作带来的风险和损失。
