检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
用于项目管理,贯穿软件开发生命周期。 华为提供开源镜像站,各服务样例工程依赖的Jar包通过华为开源镜像站下载,剩余所依赖的开源Jar包请直接从Maven中央库或者其他用户自定义的仓库地址下载,详情请参考配置华为开源镜像仓。
选择“系统设置 > 用户管理”。 在操作用户对应的“操作”列,单击“修改”。 为用户加入kafkaadmin组。 图1 为用户加入kafkaadmin组 通过命令id查询用户组信息。
使用rangeradmin用户登录Ranger管理页面。 在首页中单击“EXTERNAL AUTHORIZATION”区域的组件插件名称“OBS”。 单击“Add New Policy”,为1新建的用户组添加相应OBS路径的“Read”和“Write”权限。
以root用户登录到告警定位参数中描述的Flume ClientIP所在主机,用户密码为安装前用户自定义,请咨询系统管理员。 执行ping Flume Server IP地址命令,检查Flume Client到Flume Server的网络是否正常。 是,执行3。
图2 MRS LTS版集群版本号 版本支持情况 集群创建 MRS同一版本类型下最多同时支持两个大版本的创建。
注意:查询的字段中不能有数据类型为字符串的字段,否则会报错:java.sql.SQLException: Invalid value for getLong()。
用于项目管理,贯穿软件开发生命周期。 华为提供开源镜像站,各服务样例工程依赖的Jar包通过华为开源镜像站下载,剩余所依赖的开源Jar包请直接从Maven中央库或者其他用户自定义的仓库地址下载,详情请参考配置华为开源镜像仓。
打开MRS集群详情页面,在告警管理页签的告警列表中,单击此告警所在行,在告警详情中,查看该告警的主机名称和磁盘分区信息。 登录告警节点。 执行df -h命令,查看系统磁盘分区的使用信息。
请联系管理员获取对应账号。 基本安全认证: Spark Core和Spark SQL程序不需要访问HBase或ZooKeeper,所以使用基本的安全认证代码即可。
请联系管理员获取对应账号。 基本安全认证: Spark Core和Spark SQL程序不需要访问HBase或ZooKeeper,所以使用基本的安全认证代码即可。
job.setCombinerClass(CollectionReducer.class); // 设置作业的输出类型。
支持的表类型 Spark:Parquet、ORC、CSV、Text、Json。 Hive:Parquet、ORC、CSV、Text、RCFile、Sequence、Bucket。 数据有压缩的表在执行合并后会采用Spark默认的压缩格式-Snappy。
Tableau访问MRS HetuEngine 使用永洪BI访问MRS HetuEngine Hive对接外置自建关系型数据库 MRS Hive对接外部LDAP配置说明 使用Kafka Eagle对接MRS Kafka 使用Jupyter Notebook对接MRS Spark 集群管理类
以root用户登录客户端,用户密码为安装前用户自定义,请咨询系统管理员。
支持的表类型 Spark:Parquet、ORC、CSV、Text、Json。 Hive:Parquet、ORC、CSV、Text、RCFile、Sequence、Bucket。 数据有压缩的表在执行合并后会采用Spark默认的压缩格式-Snappy。
job.setCombinerClass(CollectionCombiner.class); // 设置作业的输出类型。
job.setCombinerClass(CollectionCombiner.class); // 设置作业的输出类型。
job.setCombinerClass(CollectionReducer.class); // 设置作业的输出类型。
以root用户登录HBase客户端,用户密码为安装前用户自定义,请咨询系统管理员。
检查磁盘是否有误写入的大文件 以omm用户登录DBService主管理节点。 执行以下命令,查看数据目录磁盘空间下超过500MB的文件,检查该目录下是否有误写入的大文件存在。