MaxCompute操作报错合集之出现无法在 information_schema.TASKS_HISTORY 表中查询到特定类型的 DI 上线任务记录,该怎么办

本文涉及的产品
云原生大数据计算服务MaxCompute,500CU*H 100GB 3个月
云原生大数据计算服务 MaxCompute,5000CU*H 100GB 3个月
简介: MaxCompute是阿里云提供的大规模离线数据处理服务,用于大数据分析、挖掘和报表生成等场景。在使用MaxCompute进行数据处理时,可能会遇到各种操作报错。以下是一些常见的MaxCompute操作报错及其可能的原因与解决措施的合集。

问题一:大数据计算MaxCompute中dhour 传参是 获取当前的年月日小时,例如当前的为:帮忙看看?

大数据计算MaxCompute中dhour 传参是 获取当前的年月日小时,例如当前的为:2024022914 to_char(dateadd(to_date('dhour,yyyymmddhh),1,hh),yyyymmddhh)selecttochar(dateadd(todate({dhour}','yyyymmddhh'),1,'hh'),'yyyymmddhh') 是在在当前年月日小时的基础上加一个小时 用这个传参的时候, select to_char(dateadd(to_date('{dhour}','yyyymmddhh'),1,'hh'),'yyyymmddhh') ; 这条代码是可以实现我要的;报错:alter table A partition ( dp ='dhour)renametopartition(dp=tochar(dateadd(todate({dhour}') rename to partition (dp = to_char(dateadd(to_date('{dhour}','yyyymmddhh'),1,'hh'),'yyyymmddhh') );


参考回答:

在MaxCompute中,可以使用dateadd函数来对日期进行加减操作,并使用to_char函数将结果转换为指定格式的字符串。

具体来说,这个表达式的作用是将输入的日期字符串(格式为'yyyymmddhh24')加上1小时,并将结果转换为'yyyymmddhh'格式的字符串。

以下是该表达式的解析:

new_dhour = to_char(dateadd(to_date('$[yyyymmddhh24]', 'yyyymmddhh'), 1, 'hh'), 'yyyymmddhh')
  • to_date('$[yyyymmddhh24]', 'yyyymmddhh'):将输入的日期字符串转换为日期类型。
  • dateadd(..., 1, 'hh'):对转换后的日期加上1小时。
  • to_char(..., 'yyyymmddhh'):将加小时后的日期转换为'yyyymmddhh'格式的字符串。

请注意,在实际使用时,需要将$[yyyymmddhh24]替换为具体的日期字符串。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/600771


问题二:大数据计算MaxCompute有一组di上线任务,数据源是hdfs,每天都运行,是什么原因呢?

大数据计算MaxCompute有一组di上线任务,数据源是hdfs,每天都运行,但是在information_schema.TASKS_HISTORY查不到运行记录,是什么原因呢?

select * from(

select distinct owner_name, get_json_object(settings,'$.SKYNET_NODENAME') as task_name

from information_schema.TASKS_HISTORY

where ds>='20240226' and task_schema = 'xxxxxx'

) where task_name='xxxxxxx'

其他di类型可以查到


参考回答:

可能的原因有以下几点:

  1. 任务没有成功执行。请检查任务的执行情况,确保任务已经成功执行。
  2. 任务的历史记录被清除了。请检查MaxCompute的任务历史保留策略,确保任务的历史记录没有被清除。
  3. 查询条件不正确。请检查查询条件是否正确,确保能够查询到任务的运行记录。

建议按照以下步骤进行排查:

  1. 登录MaxCompute控制台,查看任务的执行情况,确保任务已经成功执行。
  2. 检查MaxCompute的任务历史保留策略,确保任务的历史记录没有被清除。
  3. 修改查询条件,确保能够查询到任务的运行记录。例如,可以尝试使用*代替distinct owner_name, get_json_object(settings,'$.SKYNET_NODENAME') as task_name,以便查看所有字段的信息。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/600769


问题三:大数据计算MaxCompute这是什么问题?

大数据计算MaxCompute这是什么问题?failed: ODPS-0110061: Failed to run ddltask - Modify DDL meta encounter exception : ODPS-0010000:System internal error - Metastore processing exception - Batch modify failed. ots2.0 processing error because of [ErrorCode]:OTSOutOfTransactionDataSizeLimit, [Message]:batchWriteRow partially failed, one of its errors: Transaction size exceeds the limit.RowSize:2804.TotalSize:4194614.Limit:4194304., [RequestId]:00061273-f0b1-fc5d-e623-150a6577b849, [TraceId]:null, [HttpStatus:]0 (Inner exception: batchWriteRow partially failed, one of its errors: Transaction size exceeds the limit.RowSize:2804.TotalSize:4194614.Limit:4194304.)


参考回答:

这个问题是由于MaxCompute的事务数据大小限制导致的。在执行批量写入操作时,事务的总大小超过了限制。具体来说,单个行的大小为2804字节,总大小为4194614字节,而限制为4194304字节。

要解决这个问题,您可以尝试以下方法:

  1. 减小单行数据的大小:检查您的数据模型和业务需求,看是否可以通过减少某些字段的大小或优化数据结构来减小单行数据的大小。
  2. 增加事务数据大小限制:如果您确实需要处理大量数据,可以考虑与阿里云技术支持联系,申请增加事务数据大小限制。请注意,这可能需要额外的费用和资源投入。
  3. 分批处理数据:将数据分成较小的批次进行处理,以适应当前的事务数据大小限制。这可以通过编写自定义脚本或使用MaxCompute提供的内置函数来实现。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/600767


问题四:大数据计算MaxCompute这个报错会有啥问题吗?

大数据计算MaxCompute这个报错会有啥问题吗?warning:[0,0] It is hardly to accurately estimate io size of scanning data files for upsertable transactional table on post paid scene%EF%BC%8Ctable name is Orange_DataWarehouse_1.ods_lj_paymentdetail_rt


参考回答:

这个报错信息表示在MaxCompute中,对于名为Orange_DataWarehouse_1.ods_lj_paymentdetail_rt的可更新事务表,很难准确估计扫描数据文件时的I/O大小。这可能会导致性能问题或资源浪费。

该警告通常出现在使用后付费模式的场景下,即根据实际使用的计算资源进行计费。在这种情况下,系统可能无法准确地估算出扫描数据文件所需的I/O大小,从而无法提供准确的计费信息。

要解决这个问题,您可以考虑以下几种方法:

  1. 优化查询:检查您的查询语句是否可以进一步优化,以减少扫描的数据量和I/O操作。例如,通过添加合适的过滤条件、限制返回的结果集等来减少需要处理的数据量。
  2. 调整资源:根据您的需求和预算,考虑增加MaxCompute集群的资源,如内存、CPU等,以提高查询性能和I/O效率。
  3. 分区和分桶:将大表按照某个字段进行分区或分桶,可以减少需要扫描的数据量。通过指定分区或分桶键,您可以只扫描与查询条件匹配的分区或分桶,从而提高查询效率。
  4. 索引:为需要频繁查询的列创建索引,可以加速查询操作。索引可以帮助系统快速定位到符合条件的数据,而无需扫描整个表。
  5. 物化视图:如果您经常执行相同的查询,并且查询结果不经常变化,可以考虑使用物化视图。物化视图是预先计算好的查询结果集,可以像普通表一样进行查询。通过创建物化视图,您可以将查询结果缓存起来,避免每次查询都进行计算。

请注意,以上方法仅供参考,具体解决方案可能需要根据您的具体情况进行调整和优化。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/600753

相关实践学习
基于MaxCompute的热门话题分析
本实验围绕社交用户发布的文章做了详尽的分析,通过分析能得到用户群体年龄分布,性别分布,地理位置分布,以及热门话题的热度。
SaaS 模式云数据仓库必修课
本课程由阿里云开发者社区和阿里云大数据团队共同出品,是SaaS模式云原生数据仓库领导者MaxCompute核心课程。本课程由阿里云资深产品和技术专家们从概念到方法,从场景到实践,体系化的将阿里巴巴飞天大数据平台10多年的经过验证的方法与实践深入浅出的讲给开发者们。帮助大数据开发者快速了解并掌握SaaS模式的云原生的数据仓库,助力开发者学习了解先进的技术栈,并能在实际业务中敏捷的进行大数据分析,赋能企业业务。 通过本课程可以了解SaaS模式云原生数据仓库领导者MaxCompute核心功能及典型适用场景,可应用MaxCompute实现数仓搭建,快速进行大数据分析。适合大数据工程师、大数据分析师 大量数据需要处理、存储和管理,需要搭建数据仓库?学它! 没有足够人员和经验来运维大数据平台,不想自建IDC买机器,需要免运维的大数据平台?会SQL就等于会大数据?学它! 想知道大数据用得对不对,想用更少的钱得到持续演进的数仓能力?获得极致弹性的计算资源和更好的性能,以及持续保护数据安全的生产环境?学它! 想要获得灵活的分析能力,快速洞察数据规律特征?想要兼得数据湖的灵活性与数据仓库的成长性?学它! 出品人:阿里云大数据产品及研发团队专家 产品 MaxCompute 官网 https://www.aliyun.com/product/odps 
相关文章
|
2月前
|
SQL 消息中间件 分布式计算
大数据-124 - Flink State 01篇 状态原理和原理剖析:状态类型 执行分析
大数据-124 - Flink State 01篇 状态原理和原理剖析:状态类型 执行分析
76 5
|
2天前
|
存储 分布式计算 安全
MaxCompute Bloomfilter index 在蚂蚁安全溯源场景大规模点查询的最佳实践
MaxCompute 在11月最新版本中全新上线了 Bloomfilter index 能力,针对大规模数据点查场景,支持更细粒度的数据裁剪,减少查询过程中不必要的数据扫描,从而提高整体的查询效率和性能。
|
25天前
|
负载均衡 大数据
大数据散列分区查询频率
大数据散列分区查询频率
22 5
|
1月前
|
存储 大数据 数据管理
大数据分区提高查询性能
大数据分区提高查询性能
32 2
|
1月前
|
存储 负载均衡 大数据
大数据水平分区提高查询性能
【11月更文挑战第2天】
33 4
|
1月前
|
分布式计算 Java MaxCompute
ODPS MR节点跑graph连通分量计算代码报错java heap space如何解决
任务启动命令:jar -resources odps-graph-connect-family-2.0-SNAPSHOT.jar -classpath ./odps-graph-connect-family-2.0-SNAPSHOT.jar ConnectFamily 若是设置参数该如何设置
|
2月前
|
存储 JSON 监控
大数据-167 ELK Elasticsearch 详细介绍 特点 分片 查询
大数据-167 ELK Elasticsearch 详细介绍 特点 分片 查询
57 4
|
2月前
|
消息中间件 分布式计算 NoSQL
大数据-41 Redis 类型集合(2) bitmap位操作 geohash空间计算 stream持久化消息队列 Z阶曲线 Base32编码
大数据-41 Redis 类型集合(2) bitmap位操作 geohash空间计算 stream持久化消息队列 Z阶曲线 Base32编码
29 2
|
2月前
|
消息中间件 NoSQL Kafka
大数据-116 - Flink DataStream Sink 原理、概念、常见Sink类型 配置与使用 附带案例1:消费Kafka写到Redis
大数据-116 - Flink DataStream Sink 原理、概念、常见Sink类型 配置与使用 附带案例1:消费Kafka写到Redis
192 0
|
1月前
|
存储 分布式计算 数据挖掘
数据架构 ODPS 是什么?
数据架构 ODPS 是什么?
289 7

相关产品

  • 云原生大数据计算服务 MaxCompute
  • 下一篇
    DataWorks