检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
'f1:c1','myvalue1'。 get 获取行的值或者行的指定cell的值。例如get 'test','r1'。 scan 查询表数据，参数中需指定表名和scanner，例如scan 'test'。 父主题： 使用HBase
Mapper<Object, Text, Text, IntWritable> { /** * map的输入，key为原文件位置偏移量，value为原文件的一行字符数据。 * 其map的输入key，value为文件分割方法InputFormat提供，用户不设置，默认 * 使用TextInputFormat。
port”的值。 重新打开一个客户端连接窗口，执行以下命令，使用“kafka-console-consumer.sh”从输出Topic消费数据，查看统计结果。 cd /opt/client source bigdata_env kafka-console-consumer.sh --topic
port”的值。 重新打开一个客户端连接窗口，执行以下命令，使用“kafka-console-consumer.sh”从输出Topic消费数据，查看统计结果。 cd /opt/client source bigdata_env kafka-console-consumer.sh --topic
参考配置MRS集群通过IAM委托对接OBS完成存算分离集群配置后，Flume即可运行OBS作业。 本章节适用于MRS 3.x及之后的版本。 Flume对接OBS 创建用于存放数据的OBS文件夹。 登录OBS控制台。 单击“并行文件系统”进入并行文件系统页面。 在OBS控制台并行文件系统列表中，单击已新建的文件系统名称进入详情页面。
> 告警 > 告警”，在告警列表中展开此告警的详细信息，在定位信息中单击产生该告警的主机名称。 在主机的概览界面观察“磁盘IO利用率”的实时数据5分钟左右，若磁盘IO利用率多次超过设置的阈值，请联系MRS集群管理员提升磁盘配置。 如果无“磁盘IO利用率”图表，可单击右侧下拉三角，选择“定制”并勾选对应项，单击“确定”。
> 告警 > 告警”，在告警列表中展开此告警的详细信息，在定位信息中单击产生该告警的主机名称。 在主机的概览界面观察“主机CPU使用率”实时数据5分钟左右，若CPU使用率多次超过设置的阈值，请联系MRS集群管理员提升CPU。 如果无对应图表，可单击右侧下拉三角，选择“定制”并勾选对应项，单击“确定”。
当监控的租户目录下的文件对象使用率超过用户自定义设置的阈值时触发该告警，但不影响对该目录继续写入文件。一旦超过该目录分配的最大文件对象个数，则HDFS写入数据会失败。 可能原因 告警阈值配置不合理。 租户分配的文件目录数上限不合理 处理步骤 查看阈值设置是否合理 查看告警定位信息，获取上报告警的租户名称，租户目录。
”。 单击“确定”完成安全组规则添加。 通过云专线访问FusionInsight Manager 操作前请确保云专线服务可用，并已打通本地数据中心到线上VPC的连接通道。云专线详情请参考什么是云专线。 登录MRS管理控制台。 单击集群名称进入集群详情页。 在集群详情页面的“概览”页签，单击“集群管理页面”右侧的“前往
把主节点/srv/BigData/dbdata_service/data的内容拷贝到备节点，保持文件权限和属组与主节点一样。 修改postgresql.conf配置信息，localhost修改成本节点IP，remotehost修改成对端节点IP。 登录Manager页面重启备DBServer节点。
Manager页面，在告警列表中，单击此告警所在行的，查看该告警的节点地址。 进入“主机”界面，单击告警的所在节点。 在界面观察“主机CPU使用率”实时数据5分钟左右，若CPU使用率多次超过设置的阈值，请联系MRS集群管理员提升CPU。 排查当前业务量是否处于高峰阶段。若处于高峰阶段导致该告警
> 告警”，在告警列表中展开此告警的详细信息，在定位信息中单击产生该告警的主机名称。 在主机的概览界面观察“每个读操作平均所需时间”的实时数据5分钟左右，若磁盘IO利用率多次超过设置的阈值，请联系MRS集群管理员提升磁盘配置。 如果无“每个读操作平均所需时间”图表，可单击右侧下拉
port”的值。 重新打开一个客户端连接窗口，执行以下命令，使用“kafka-console-consumer.sh”从输出Topic消费数据，查看统计结果。 cd /opt/client source bigdata_env kafka-console-consumer.sh --topic
port”的值。 重新打开一个客户端连接窗口，执行以下命令，使用“kafka-console-consumer.sh”从输出Topic消费数据，查看统计结果。 cd /opt/client source bigdata_env kinit 组件操作用户（例如developuser）
ger都能访问。当前系统提供了三种共享状态信息的方法：通过文件系统共享（FileSystemRMStateStore）、通过LevelDB数据库共享（LeveldbRMStateStore）或通过ZooKeeper共享（ZKRMStateStore）。这三种方式中只有ZooKee
port”的值。 重新打开一个客户端连接窗口，执行以下命令，使用“kafka-console-consumer.sh”从输出Topic消费数据，查看统计结果。 cd /opt/client source bigdata_env kinit 组件操作用户（例如developuser）
flink-dist_*.jar flink-dist_*.jar可在Flink的客户端或者服务端安装路径的lib目录下获取。 向Kafka生产并消费数据程序样例工程（Java/Scala） kafka-clients-*.jar flink-connector-kafka_*.jar fl
Python3开发环境的基本配置，版本如47.3.1。 jaydebeapi Python3开发环境的基本配置，可以通过该模块使用Java的JDBC来连接数据库。 准备运行环境 进行应用开发时，需要同时准备代码的运行调测的环境，用于验证应用程序运行正常。 如果本地Windows开发环境和集群业务平
Broker上分区分布不均衡示例 是，执行13。 否，执行11。 单击最右侧分区不均衡的条柱，查看是否包含5中获取的当前告警上报的节点，如果包含则需要执行数据均衡。 等待5分钟，查看告警是否自动清除。 是，操作结束。 否，执行13。 收集故障信息。 在FusionInsight Manager界面，选择“运维
Broker上分区分布不均衡示例 是，执行13。 否，执行11。 单击最右侧分区不均衡的条柱，查看是否包含5中获取的当前告警上报的节点，如果包含则需要执行数据均衡。 等待5分钟，查看告警是否自动清除。 是，操作结束。 否，执行13。 收集故障信息。 在FusionInsight Manager界面，选择“运维
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
