检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
登录到FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 实例”，勾选所有Broker实例，单击“启动实例”。 给MRS服务集群的Broker节点分别绑定EIP。 在Windows通过已配置的Broker节点EIP地址和端口连接到Kafka集群并调试代码。
登录到FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 实例”，勾选所有Broker实例，单击“启动实例”。 给MRS服务集群的Broker节点分别绑定EIP。 在Windows通过已配置的Broker节点EIP地址和端口连接到Kafka集群并调试代码。
访问Hue原生页面时间长，文件浏览器报错Read timed out 问题 访问Hue原生页面时页面加载时间较长，访问Hue的HDFS文件浏览器报错Read timed out，如何解决。 回答 检查HDFS服务中是否安装Httpfs实例。 否，请联系运维人员处理。 是，重启HttpFS实例解决。 父主题： Hue常见问题
站点。 前提条件 访问MRS集群Manager前，确保集群不处于启动中、停止中、停止、删除中、已删除、冻结状态。 操作视频 本视频为您介绍如何为MRS集群绑定弹性公网IP，并访问集群中组件的WebUI页面。 因不同版本操作界面可能存在差异，相关视频供参考，具体以实际环境为准。 通
登录到FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 实例”，勾选所有Broker实例，单击“启动实例”。 给MRS服务集群的Broker节点分别绑定EIP。 在Windows通过已配置的Broker节点EIP地址和端口连接到Kafka集群并调试代码。
登录到FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 实例”，勾选所有Broker实例，单击“启动实例”。 给MRS服务集群的Broker节点分别绑定EIP。 在Windows通过已配置的Broker节点EIP地址和端口连接到Kafka集群并调试代码。
站点。 前提条件 访问MRS集群Manager前，确保集群不处于启动中、停止中、停止、删除中、已删除、冻结状态。 操作视频 本视频为您介绍如何为MRS集群绑定弹性公网IP，并访问集群中组件的WebUI页面。 因不同版本操作界面可能存在差异，相关视频供参考，具体以实际环境为准。 通
errors.count() textFile算子从HDFS读取日志文件，返回file（作为RDD）。 filter算子筛出带“ERROR”的行，赋给errors（新RDD）。filter算子是一个Transformation操作。 cache算子缓存下来以备未来使用。 count算子返回
访问Hue原生页面时间长，文件浏览器报错Read timed out 问题 访问Hue原生页面时页面加载时间较长，访问Hue的HDFS文件浏览器报错Read timed out，如何解决。 回答 检查HDFS服务中是否安装Httpfs实例。 否，请联系运维人员处理。 是，重启HttpFS实例解决。 父主题： Hue故障排除
导入并配置HBase样例工程 背景信息 获取HBase开发样例工程，将工程导入到IntelliJ IDEA开始样例学习。 前提条件 确保本地PC的时间与集群的时间差要小于5分钟，若无法确定，请联系系统管理员。集群的时间可通过FusionInsight Manager页面右下角查看。
导入并配置Flink样例工程 操作场景 Flink针对多个场景提供样例工程，包含Java样例工程和Scala样例工程等，帮助客户快速学习Flink工程。 针对Java和Scala不同语言的工程，其导入方式相同。 以下操作步骤以导入Java样例代码为例。操作流程如图1所示。 图1 导入样例工程流程
字段名：需填写上一个转换步骤生成的字段名，可添加多个。 map 是 无 数据处理规则 按顺序将“被拼接字段名”中配置的字段的值，通过连接符拼接后，赋给“输出字段名”。 当有字段的值为null时，会转化为空字符串，再与其它字段值拼接。 样例 通过“CSV文件输入”算子，生成三个字段A、B和C。
导入并配置Flink样例工程 操作场景 Flink针对多个场景提供样例工程，包含Java样例工程和Scala样例工程等，帮助客户快速学习Flink工程。 针对Java和Scala不同语言的工程，其导入方式相同。 以下操作步骤以导入Java样例代码为例。操作流程如图1所示。 图1 导入样例工程流程
用户问题 安全集群Alluixo在HA模式下出现Does not contain a valid host:port authority的报错，如何处理？ 问题现象 安全集群中，Alluixo在HA模式下出现Does not contain a valid host:port authority的报错。
字段名：需填写上一个转换步骤生成的字段名，可添加多个。 map 是 无 数据处理规则 按顺序将“被拼接字段名”中配置的字段的值，通过连接符拼接后，赋给“输出字段名”。 当有字段的值为null时，会转化为空字符串，再与其他字段值拼接。 样例 通过“CSV文件输入”算子，生成三个字段A、B和C。
serializable result: org.apache.hadoop.hbase.io.ImmutableBytesWritable，应该如何处理？ 回答 可通过如下两种方式处理： 在代码的SparkConf初始化之前执行以下两行代码： System.setProperty("spark
导入并配置Flink样例工程 操作场景 Flink针对多个场景提供样例工程，包含Java样例工程和Scala样例工程等，帮助客户快速学习Flink工程。 针对Java和Scala不同语言的工程，其导入方式相同。 以下操作步骤以导入Java样例代码为例。操作流程如图1所示。 图1 导入样例工程流程
> 服务 > Spark > 配置 > 全部配置 ”。 在左侧的导航列表中选择“SparkResource > 自定义”。在自定义配置项中，给参数“custom”添加配置项“spark.sql.warehouse.location.first”，设置值为“true”。 图1 spark
在Linux环境中调测Spark应用 在程序代码完成开发后，您可以上传至Linux客户端环境中运行应用。使用Scala或Java语言开发的应用程序在Spark客户端的运行步骤是一样的。 使用Python开发的Spark应用程序无需打包成jar，只需将样例工程复制到编译机器上即可。
在Linux环境中调测Spark应用 在程序代码完成开发后，您可以上传至Linux客户端环境中运行应用。使用Scala或Java语言开发的应用程序在Spark客户端的运行步骤是一样的。 使用Python开发的Spark应用程序无需打包成jar，只需将样例工程复制到编译机器上即可。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
