检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
map、reduce两个阶段都处理在<key,value>键值对上，也就是说，框架把作业的输入作为一组<key,value>键值对，同样也产出一组<key,value>键值对作为作业的输出，这两组键值对的类型可能不同。
AK/SK既可以使用永久访问密钥中的AK/SK，也可以使用临时访问密钥中的AK/SK，但使用临时访问密钥的AK/SK时需要额外携带“X-Security-Token”字段，字段值为临时访问密钥的security_token。
private var count = 0L // 设置用户自定义状态 def setState(s: Long) = count = s // 获取用户自定状态 def getState = count } 带checkpoint的数据源 source算子的代码，该段代码每发送
bin/spark-submit --master yarn --deploy-mode cluster --jars SparkOnHbaseJavaExample-1.0.jar HBaseBulkGetExample.py bulktable Java样例代码 下面代码片段仅为演示
bin/spark-submit --master yarn --deploy-mode cluster --jars SparkOnHbaseJavaExample-1.0.jar HBaseBulkGetExample.py bulktable Java样例代码 下面代码片段仅为演示
spark-submit --master yarn --deploy-mode cluster --jars SparkOnHbaseJavaExample-1.0.jar HBaseForEachPartitionExample.py table2 cf1 Java样例代码 下面代码片段仅为演示
提交MapReduce任务时客户端长时间无响应 问题 向YARN服务器提交MapReduce任务后，客户端长时间无响应。 回答 对于上述出现的问题，ResourceManager在其WebUI上提供了MapReduce作业关键步骤的诊断信息，对于一个已经提交到YARN上的MapReduce
集群名信息可以使用以下语句的cluster字段获取： select cluster,shard_num,replica_num,host_name from system.clusters; 使用示例 --创建数据库名为test的数据库 CREATE DATABASE test ON
集群名信息可以使用以下语句的cluster字段获取： select cluster,shard_num,replica_num,host_name from system.clusters; 使用示例 --创建数据库名为test的数据库 CREATE DATABASE test ON
map、reduce两个阶段都处理在<key,value>键值对上，也就是说，框架把作业的输入作为一组<key,value>键值对，同样也产出一组<key,value>键值对作为作业的输出，这两组键值对的类型可能不同。
this.count = count; } // 获取用户自定义状态 public long geState() { return this.count; } } 带checkpoint的数据源 source算子的代码，该段代码每发送
this.count = count; } // 获取用户自定义状态 public long geState() { return this.count; } } 带checkpoint的数据源 source算子的代码，该段代码每发送
) println("Length: " + getRdd.map(r => r._1.copyBytes()).collect().length); } finally { sc.stop() } } Python样例代码 下面代码片段仅为演示
) println("Length: " + getRdd.map(r => r._1.copyBytes()).collect().length); } finally { sc.stop() } } Python样例代码 下面代码片段仅为演示
权限要求 表1 操作权限要求 操作类型/作用对象 操作 权限要求 DATABASE CREATE DATABASE dbname [LOCATION "hdfs_path"] 如果指定了HDFS路径hdfs_path，需要是路径hdfs_path的所有者和具有RWX权限。
查看该告警“定位信息”中对应的“主机名”字段值，获取该告警产生的主机名，查看定位信息中对应的“路径名”字段值，获取异常的文件路径或者名称。 以root用户登录告警所在节点，用户密码为安装前用户自定义，请咨询系统管理员。
spark.yarn.user.classpath.first=true --jars SparkOnHbaseJavaExample-1.0.jar,/opt/female/protobuf-java-2.5.0.jar HBaseSource.py Java样例代码 面代码片段仅为演示
spark.yarn.user.classpath.first=true --jars SparkOnHbaseJavaExample-1.0.jar,/opt/female/protobuf-java-2.5.0.jar HBaseSource.py Java样例代码 面代码片段仅为演示
单击“Audit”，查看相关审计信息，各页签内容说明请参考表1，条目较多时，单击搜索框可根据关键字字段进行筛选。
代码样例 下面代码片段在com.huawei.storm.example.common.RandomSentenceSpout类中，作用在于将收到的字符串拆分成单词。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
