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
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)