采用spark引擎跑sql,insert overwrite select方式覆盖写数据表时,spark某些版本覆盖写不会重置表的schema;
所以建议如果数据表中间有插入新字段,schema改变的话,覆盖写数据之前先删除分区
ALTER TABLE udw_ns.default.XXX DROP IF EXISTS PARTITION (event_day='{YESTERDAY}');insert overwrite XXX select ...;
采用spark引擎跑sql,insert overwrite select方式覆盖写数据表时,spark某些版本覆盖写不会重置表的schema;
所以建议如果数据表中间有插入新字段,schema改变的话,覆盖写数据之前先删除分区
ALTER TABLE udw_ns.default.XXX DROP IF EXISTS PARTITION (event_day='{YESTERDAY}');insert overwrite XXX select ...;
Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:
部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。