代码如下:
----新建临时表1用于存放数据质量是否产生告警
drop table if exists TMP_DWD_DATA_CHECK_REPORT_001_${vDay};
create table TMP_DWD_DATA_CHECK_REPORT_001_${vDay}(
CHECK_RULE_ID STRING COMMENT '核查规则编码',
WARNING_STATUS STRING COMMENT '是否告警'
)COMMENT '数据质量监控规则告警状态';
具体是哪个产品执行的呢?如果对应的产品不支持变量传入的话这里的drop table 和 create table中的 ${vDay} 就会产生语法错误。
解决方法
这个报错比较常见的原因是 Reduce 里做了大循环,比如存在长尾数据或者做笛卡尔积。您需要尽量减少这种大循环的情况。
对于长尾数据,可以考虑拿出来单独处理。或者您可以手动发心跳,调用 context.progress(); 但是这个有性能问题,不适合调用太频繁。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。