检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Impala启用并配置动态资源池 本文介绍如何使用动态资源池控制impala并发。 问题背景 客户需要使用动态资源池控制impala并发。
Presto并发执行的任务过多。 处理步骤 检查任务并发量 检查当前集群CPU负载是否正常，SQL并发量是否符合预期。 是，执行2。 否，执行4。 调整线程数告警触发阈值。
Presto并发执行的任务过多。 处理步骤 检查任务并发量 检查当前集群CPU负载是否正常，SQL并发量是否符合预期。 是，执行2。 否，执行4。 调整线程数告警触发阈值。
在Beeline/JDBCServer模式下连续运行10T的TPCDS测试套会出现内存不足的现象 问题 在Driver内存配置为10G时，Beeline/JDBCServer模式下连续运行10T的TPCDS测试套，会出现因为Driver内存不足导致SQL语句执行失败的现象。
Presto并发执行的任务过多。 处理步骤 检查任务并发量 检查当前集群CPU负载是否正常，SQL并发量是否符合预期。 是，执行2。 否，执行4。 调整线程数告警触发阈值。
不建议对同一张表并发插入数据，因为有一定概率发生并发冲突，导致插入失败。 时间戳格式只支持yyyy-MM-dd hh:mm:ss。 示例 在opentsdb_table表中插入数据。
Presto并发执行的任务过多。 处理步骤 检查任务并发量 检查当前集群CPU负载是否正常，SQL并发量是否符合预期。 是，执行2。 否，执行4。 调整线程数告警触发阈值。
Presto并发执行的任务过多。 处理步骤 检查任务并发量 检查当前集群CPU负载是否正常，SQL并发量是否符合预期。 是，执行2。 否，执行4。 调整线程数告警触发阈值。
在Beeline/JDBCServer模式下连续运行10T的TPCDS测试套会出现内存不足的现象 问题 在Driver内存配置为10G时，Beeline/JDBCServer模式下连续运行10T的TPCDS测试套，会出现因为Driver内存不足导致SQL语句执行失败的现象。
最大并发数：根据界面要求设置日志收集时的最大节点并发数量。（MRS 3.3.0及之后版本支持该参数） 单击右上角的设置日志的起始收集时间“开始时间”和“结束时间”。 单击“下载”完成日志下载。 下载的日志压缩包中会包括对应开始时间和结束时间的拓扑信息，方便查看与定位。
集群在线扩缩容 大数据集群的处理能力通常可以通过增加集群的节点数来横向扩展，当集群规模不符合业务要求时，用户可以通过该功能进行集群节点规模的调整，进行扩容或者缩容；在缩容节点时，MRS会智能地选择负载最少或者迁移数据量最小节点，并且在缩容过程中，缩容节点不再接收新的任务，正在执行的任务继续执行
原因分析 系统并发量较大或数据量大导致任务执行超时。 处理步骤 登录MySQL客户端，执行以下命令适当调大“query_timeout”参数值，默认为300秒。
否，执行3，修改并发Impalad支持的并发连接数。
单击“测试”。 如果显示测试成功，则执行6。 如果显示测试失败，则需要重复4。 单击“保存”。 如果某个Loader作业已集成一个Loader连接，那么编辑连接参数后可能导致Loader作业运行效果也产生变化。 删除连接 在Loader页面，单击“新建作业”。
在线检索MRS集群日志 MRS集群Manager支持在线检索并显示组件的日志内容，用于问题定位等其他日志查看场景，管理员可在线按照节点范围或者组件角色范围快速检视所有日志，通过关键字分析快速定位问题。 本章节操作仅支持MRS 3.x及之后的版本。
网络连接超时导致FetchFailedException 问题 在380节点的大集群上，运行29T数据量的HiBench测试套中ScalaSort测试用例，使用以下关键配置（--executor-cores 4）出现如下异常： org.apache.spark.shuffle.FetchFailedException
网络连接超时导致FetchFailedException 问题 在380节点的大集群上，运行29T数据量的HiBench测试套中ScalaSort测试用例，使用以下关键配置（--executor-cores 4）出现如下异常： org.apache.spark.shuffle.FetchFailedException
数据传输加解密对性能影响较大，经过测试发现具有200%的性能差异，因此建议性能测试时关闭SSL加密。ConfigNode和IoTDBServer两个角色同名参数都要修改。
下面代码片段在com.huawei.bigdata.kafka.example.ConsumerMultThread类的run方法中，用于实现对指定Topic的并发消费。 代码样例 /** * 启动多线程并发消费Consumer。
下面代码片段在com.huawei.bigdata.kafka.example.ConsumerMultThread类的run方法中，用于实现对指定Topic的并发消费。 代码样例 /** * 启动多线程并发消费Consumer。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
