Doris动态分区表routineLoad报错

报错Reason: no partition for this tuple. tuple=。。。。。分析kafka中的数据进来了，但是动态分区表没有创建这条数据的时间分区解决#给动态分区添加分区##动态分区转静态分区ALTER TABLE ods_log_outlog_course_ydyjs_app SET ("dynamic_partition.enable" = "false");##添加未

Geoffrey Turing

4398人浏览 · 2022-01-12 16:16:04

Geoffrey Turing · 2022-01-12 16:16:04 发布

报错

Reason: no partition for this tuple. tuple=。。。。。

分析

kafka中的数据进来了，但是动态分区表没有创建这条数据的时间分区

解决

#给动态分区添加分区

##动态分区转静态分区
ALTER TABLE ods_log_outlog_course_ydyjs_app SET ("dynamic_partition.enable" = "false");

##添加未创建的分区
ALTER TABLE course_log.ods_log_outlog_course_ydyjs_app
        ADD PARTITION p20220307 VALUES [("2022-03-07"), ("2022-03-08"));
##添加未创建的分区        
ALTER TABLE course_log.ods_log_outlog_course_ydyjs_app
        ADD PARTITION p20220308 VALUES [("2022-03-08"), ("2022-03-09"));

##查看是否创建成功        
show partitions from ods_log_outlog_course_ydyjs_app;

##静态分区恢复成动态分区
ALTER TABLE ods_log_outlog_course_ydyjs_app SET ("dynamic_partition.enable" = "true");

## resume routineLoad任务
resume routine load for ods_log_outlog_course_ydyjs_app_load