检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
通过Manager添加子租户(MRS 3.x及之后版本) 登录MRS集群Manager界面,单击“租户资源”。 登录集群Manager界面请参考访问MRS集群Manager。 在左侧租户列表,选择父租户节点然后单击,打开添加子租户的配置页面,配置相关参数。 使用Superior调度器集群请参考表3为子租户配置属性。
`product_desc2` String TTL create_time + toIntervalMonth(10), `product_desc3` String TTL create_time + toIntervalHour(10) ) ENGINE = MergeTree() PARTITION
WebUI界面默认初始账号密码admin/123456 登录后可以查看Kafka集群监控页面、Topic监控页面、Consumer监控页面,例如: 图3 Kafka集群监控 图4 Topic监控 图5 Consumer监控 Kafka Eagle对接常见问题 问题现象: 无法获取Kafka CPU与内存监控信息日志提示。
选择对应的过滤条件,输入查询条件值进行过滤查询。 表1 慢查询界面过滤条件 条件 参数说明 慢查询运行时长大于 按照慢查询SQL语句查询累计时长过滤查询。 支持时长大于:3(s)、9(s)、15(s)、25(s)。 按查询id 根据查询界面对应慢查询语句的“查询id”字段过滤查询。 支持按照“查询id”的部分值
textfile; 单击执行HQL。 图2 执行语句 在命令输入框内输入: show tables; 单击,查看“结果”中有创建的表hue_table。 图3 查看结果 父主题: 创建Hue操作任务
选择所需修改的日志级别。 保存配置,在弹出窗口中单击“确定”使配置生效。 配置完成后立即生效,不需要重启服务。 日志格式 HBase的日志格式如下所示: 表3 日志格式 日志类型 实例名称 格式 示例 运行日志 HMaster <yyyy-MM-dd HH:mm:ss,SSS>|<Log Leve
mv_validity = '1h', start_refresh_ahead_of_expiry = 0.2, refresh_priority = 3, refresh_duration = '5m') AS select id from hive.mvschema.t1; need_auto_refresh:是否启用自动刷新
spark_connector_test_decimal ( c1 int NOT NULL, c2 VARCHAR(25) NOT NULL, c3 VARCHAR(152), c4 boolean, c5 tinyint, c6 smallint, c7 bigint, c8 float
压过载,当过大请求可以被认为是异常请求时,可以在Manager界面的HBase配置中调整RegionServer以下参数拒绝对应请求。 表3 请求拒绝相关参数调整 参数名称 参数描述 调整策略 hbase.ipc.max.request.size RegionServer单个请求
ample_tbl的分区p1和p2,以及恢复表example_tbl2到数据库example_db1,并重命名为new_tbl,默认恢复为3个副本: RESTORE SNAPSHOT example_db1.`snapshot_label2` FROM `example_repo`
Doris管理员权限为:除去节点操作权限外的所有权限。 角色名称:添加的角色名不能包含中划线字符“-”,并且不能以数字开头。 是,执行3。 否,执行4。 勾选“Doris管理员权限”,单击“确定”,完成角色创建。 单击“Doris读写权限”,勾选对应资源的“查询”、“删除”、
usr partition(country='CN') VALUES(1,'maxwell',45),(2,'minwell',30),(3,'mike',22); INSERT INTO TABLE test.usr partition(country='USA') VALUES(4
要使用的HBase表: create 'HBaseSourceExampleTable','rowkey','cf1','cf2','cf3','cf4','cf5','cf6','cf7', 'cf8' 开发思路 创建RDD. 以数据源的方式操作HBase,将上面生成的RDD写入HBase表中
dfs.close(); dfsAdmin.close(); } 创建group 样例:创建一个gid01组,组中包含3个locator。 private static void createGroup() throws IOException {
brokers = args[1]; String topics = args[2]; String batchSize = args[3]; //新建一个Streaming启动环境. SparkConf sparkConf = new SparkConf()
检查用户密码:登录Manager使用的用户密码错误或失效。 处理步骤 登录MRS管理控制台页面,选择“现有集群”,查看MRS集群运行状态是否正常。 是,执行3。 否,如果MRS集群状态异常或正在创建中,或集群正在发生主备倒换,请先排查集群故障、或等待集群创建完成、或集群主备倒换完成后再尝试访问Manager。
选择所需修改的日志级别。 保存配置,在弹出窗口中单击“确定”使配置生效。 配置完成后立即生效,不需要重启服务。 日志格式 HBase的日志格式如下所示: 表3 日志格式 日志类型 组件 格式 示例 运行日志 HMaster <yyyy-MM-dd HH:mm:ss,SSS>|<Log Level>
都属于同样的消费组,它们就以传统队列负载均衡方式工作。如上图中,Consumer1与Consumer2之间为负载均衡方式;Consumer3、Consumer4、Consumer5与Consumer6之间为负载均衡方式。如果消费者实例都属于不同的消费组,则消息会被广播给所有消费者
"mrs:cluster:resize" ] } ] } 示例3:授权用户创建集群、创建并执行作业、删除单个作业,但不允许用户删除集群的权限。 { "Version": "1.1", "Statement":
'obs://mrs-word001/table/'; 执行如下命令查询所有表,返回结果中存在表test,即表示访问OBS成功。 show tables; 图3 Spark2x验证返回已创建的表名 使用“Ctrl + C”退出spark beeline。 使用spark sql对接OBS 使用安装客户端用户登录客户端安装节点。