检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Storm WebUI页面中events超链接地址无效 用户问题 Storm组件的Storm UI页面中events超链接地址无效。 问题现象 用户提交拓扑后无法查看拓扑数据处理日志,按钮events地址无效。 原因分析 MRS集群提交拓扑时默认不开启拓扑数据处理日志查看功能。
Flink对接云搜索服务(CSS)样例程序(Java) 功能介绍 当前基于随机数生成器实现了一个持续产生长度为4字符串的数据源用于写入数据。 样例代码 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.flink.examples。
"," + row.getLong(1); } }).collect(); System.out.println(result); jsc.stop(); 上面是简单示例,其它sparkSQL特性请参见如下链接
原因分析 备份目录软链接到系统盘,系统盘满了之后备份任务失败。 处理步骤 检查备份目录是否软链接到系统盘。 以root用户登录集群主备Master节点。 执行df -h命令查看磁盘情况,检查系统盘的存储情况。
row.getLong(1); } }).collect(); System.out.println(result); spark.stop(); } 上面是简单示例,其它SparkSQL特性请参见如下链接
row.getLong(1); } }).collect(); System.out.println(result); spark.stop(); } 上面是简单示例,其它sparkSQL特性请参见如下链接
问题现象 未开启Kerberos认证的集群,访问MRS Manager页面报错如下图: 图1 MRS Manager页面报错 原因分析 由于MRS的域名由console-emr变更为mrs导致普通集群访问MRS Manager的链接有误。
这些组件可以链接以形成多个数据流。
筛选出时间大于两个小时的女性网民信息,并输出 val c = femaleTimeInfo.filter("stayTime >= 120").collect() c.foreach(println) sc.stop() } } 上面是简单示例,其它sparkSQL特性请参见如下链接
登录Tez WebUI界面 登录Manager系统,具体请参见访问集群Manager,在Manager界面选择“集群 > 服务 > Tez”,在“基本信息”中单击“Tez WebUI”右侧的链接,打开Tez WebUI。可查看执行的Tez任务执行细节。 父主题: 使用Tez
其他表引擎详细可以参考官网链接:https://clickhouse.tech/docs/en/engines/table-engines。
S3(path, [ak, sk,] format, structure, [compression]) path:访问域名/OBS文件路径,登录OBS管理控制台,在左侧导航栏单击“并行文件系统”,在“并行文件系统”页面单击对应的文件系统名称,在“文件”页面单击文件名称,文件“链接
openQueues= ^default$ 原因分析 页面链接无法识别符号“^”,导致页面访问失败。 处理步骤 登录Manager页面,选择“集群 > 服务 > Yarn > 配置 > 全部配置”。
筛选出时间大于两个小时的女性网民信息,并输出 val c = femaleTimeInfo.filter("stayTime >= 120").collect().foreach(println) spark.stop() } } 上面是简单示例,其它sparkSQL特性请参见如下链接
语法 REFRESH CATALOG catalog_name 示例 登录FusionInsight Manager,选择“服务 > HetuEngine > 概览”,单击“HSConsole WebUI”后的HSConsole链接进入计算实例界面,然后选择“数据源 > hive数据源名称
筛选出时间大于两个小时的女性网民信息,并输出 val c = femaleTimeInfo.filter("stayTime >= 120").collect().foreach(println) spark.stop() } } 上面是简单示例,其它sparkSQL特性请参见如下链接
选择“集群 > 服务 > CDL”,单击“CDLService UI”右侧的超链接进入CDL WebUI界面,选择该作业所在行的“更多 > 停止”,停止CDL任务。任务停止成功后,再单击“启动”,重新启动该任务。 父主题: CDL故障排除
筛选出时间大于两个小时的女性网民信息,并输出 val c = femaleTimeInfo.filter("stayTime >= 120").collect().foreach(println) spark.stop() } } 上面是简单示例,其它sparkSQL特性请参见如下链接
筛选出时间大于两个小时的女性网民信息,并输出 val c = femaleTimeInfo.filter("stayTime >= 120").collect().foreach(println) spark.stop() } } 上面是简单示例,其它sparkSQL特性请参见如下链接
在概览页签下的“基本信息”区域,单击“HSConsole WebUI”后的链接,进入HSConsole界面。 单击“计算实例”,选择对应租户名下待操作的计算实例。