OMS看似是时间问题导致异常报错

【 使用环境 】测试环境
【 OB or 其他组件 】OMS 4.2.10
【 使用版本 】4.2.10
【问题描述】

老师,您好,我们在同步过程中,date 类型出现了 0 的日期,然后报错“MonthOfYear ”,请问如何跳过呢?


981
at java.lang.Thread.run(Thread.java:853)
982
Caused by: com.oceanbase.oms.connector.common.exception.ConnectorException: ErrorCode: SERIALIZATION_ERROR(oms.connector.serialization.error), msg: record meta[testc.ftsp_testc-crm_kh_qzkh_city,1755072011,UPDATE,1755072010]prev[Struct{qzkh_id(VAR_CHAR_STRING)=h0000000000000098228538434469929,qzkh_mc(VAR_CHAR_STRING)=杭州尊古门酒业有限公司,emp_id(VAR_CHAR_STRING)=null,hzxz_(INT8)=2,mphone(VAR_CHAR_STRING)=N+DXElZVK9qaipybASORAy/UX9j3DrAQEEyyvfJynVk=,dhhm(VAR_CHAR_STRING)=,e_mail(VAR_CHAR_STRING)=null,internet(VAR_CHAR_STRING)=083ecebefc33dc4e87ef27eab183a5dd01,add_prov(VAR_CHAR_STRING)=330000,add_city(VAR_CHAR_STRING)=330100,add_area(VAR_CHAR_STRING)=330104,address(VAR_CHAR_STRING)=杭州市市场监督管理局经济技术开发区分局,cjrq(DATETIME)=2025-04-09 03:02:43,cjr(VAR_CHAR_STRING)=h0000000000000722971377324105728,cjr_name_(VAR_CHAR_STRING)=null,sfr(VAR_CHAR_STRING)=null,khly_dm(CHAR_STRING)=2,hy_dm(VAR_CHAR_STRING)=51,ms(VAR_CHAR_STRING)=null,lxr(VAR_CHAR_STRING)=张三,sjlx(CHAR_STRING)=0,create_time(DATETIME)=0000-00-00 00:00:00,cust_lx(INT8)=1,nsrlx_status_(INT8)=0,last_visit_time(DATETIME)=2024-01-29 15:16:12,last_visit_record(VAR_CHAR_STRING)=null,last_call_time_(DATETIME)=2024-01-29 15:15:53,last_gt_jg_(VAR_CHAR_STRING)=null,wh_status_(INT8)=0,yssj_ly(VAR_CHAR_STRING)=13,yssj_ly_sj(DATE)=null,yssj_cjr(VAR_CHAR_STRING)=null,yssj_cjr_name_(VAR_CHAR_STRING)=null,yssj_cjr2_(VAR_CHAR_STRING)=null,yssj_cjr_name2_(VAR_CHAR_STRING)=null,yssj_ly_sj2_(DATE)=null,zc_rq_(CHAR_STRING)=20180131,sign_type_(CHAR_STRING)=0,yssj_jgly(VAR_CHAR_STRING)=88888888888888888888888888888888,zcjg(VAR_CHAR_STRING)=null,belong_jgid_(VAR_CHAR_STRING)=88888888888888888888888888888888,khyxd_(CHAR_STRING)=null,is_zxh_(INT8)=null,has_yxth_(INT8)=null,has_yx_(INT8)=null,fwqx_z_(VAR_CHAR_STRING)=null,infra_bq_id(VAR_CHAR_STRING)=h0000000000000396934128592814080,h0000000000000396934128592814081,has_yhq_(CHAR_STRING)=null,infra_khbqz_id_(VAR_CHAR_STRING)=null,khbqz_size_(INT8)=null,marketing_stage_(INT8)=1,association_set_id_(CHAR_STRING)=null,clue_source_(CHAR_STRING)=0106,clue_channel_(CHAR_STRING)=null,organization_type_(CHAR_STRING)=0201,operation_status_(CHAR_STRING)=0402,communication_attitude_(CHAR_STRING)=null,listen_attitude_(CHAR_STRING)=null,cooperation_attitude_(CHAR_STRING)=null,appointment_attitude_(CHAR_STRING)=null,clue_validity_(INT8)=0,bookkeeping_condition_(CHAR_STRING)=null,prejudged_demand_(INT8)=0,has_contract_(CHAR_STRING)=null,pay_period_(CHAR_STRING)=null,expire_year_month_(INT24)=200000,business_income_(INT24)=null,voucher_amount_(INT24)=null,invoice_amount_(INT24)=null,declaration_status_(CHAR_STRING)=null,has_five_insurances_(CHAR_STRING)=null,has_housing_funds_(CHAR_STRING)=null,intent_level_(INT8)=2,highest_intent_level_(INT8)=2,social_credit_code_(VAR_CHAR_STRING)=91330101MA2B0N1MXP,operation_scope_(VAR_CHAR_STRING)=食品销售;技术开发、技术服务、技术咨询、成果转让:网络信息技术、计算机软硬件、电子商务技术、计算机系统集成;服务:承接计算机网络工程,利用信息网络经营游戏产品(含网络游戏虚拟货币发行),第二类增值电信业务中的信息服务业务(仅限互联网信息服务,不含新闻、出版、教育、医疗保健、药品和医疗器械、文化、广播电影电视节目等内容的信息服务、电子公告业务),机械设备租赁;批发、零售:计算机软硬件,通讯设备(除国家专控),电子产品,工艺美术品,日用百货,办公用品,机电设备,普通机械、图书、音像制品、初级食品农产品(除食品、药品)、服装、服饰、箱包、玩具(除国家专控)、母婴用品(除奶粉)、家纺用品、针织纺品、办公用品、电子元器件、数码产品、仪器仪表、体育用品及器材、化妆品(除分装)、卫生用品、第一类医疗器械、五金交电、建筑材料、装饰材料、包装材料、网络设备。(依法须经批准的项目,经相关部门批准后方可开展经营活动),kh_scene_wash_(INT16)=82,kh_scene_follow_(INT32)=2048,kh_scene_push_(INT8)=0,is_association_applied_(INT8)=0,update_date_(TIMESTAMP_IN_LONG)=1744138963.262000,is_qy_(CHAR_STRING)=0,qualification_(VAR_CHAR_STRING)=null,position_(VAR_CHAR_STRING)=null,dhhm_status_(VAR_CHAR_STRING)=null,mphone_status_(VAR_CHAR_STRING)=null,xxxq_demand_(VAR_CHAR_STRING)=null,intent_level_his_(CHAR_STRING)=2,2,2,2,2,intent_level_date_(DATETIME)=2020-11-17 19:36:57,tjdz_(VAR_CHAR_STRING)=null,yjcdrq_(DATE)=null,last_bj_date_(DATETIME)=null,last_bj_je_(NUMBER)=null,original_clue_source_(CHAR_STRING)=0106,source_update_date_(TIMESTAMP_IN_LONG)=null,work_wechat_status_(INT8)=0,kh_portrait_id_(VAR_CHAR_STRING)=null,encrypt_upgrade_status_(INT32)=0}] post[Struct{qzkh_id(VAR_CHAR_STRING)=h0000000000000098228538434469929,qzkh_mc(VAR_CHAR_STRING)=杭州尊古门酒业有限公司,emp_id(VAR_CHAR_STRING)=null,hzxz_(INT8)=2,mphone(VAR_CHAR_STRING)=N+DXElZVK9qaipybASORAy/UX9j3DrAQEEyyvfJynVk=,dhhm(VAR_CHAR_STRING)=,e_mail(VAR_CHAR_STRING)=null,internet(VAR_CHAR_STRING)=083ecebefc33dc4e87ef27eab183a5dd01,add_prov(VAR_CHAR_STRING)=330000,add_city(VAR_CHAR_STRING)=330100,add_area(VAR_CHAR_STRING)=330104,address(VAR_CHAR_STRING)=杭州市市场监督管理局经济技术开发区分局,cjrq(DATETIME)=2025-04-09 03:02:43,cjr(VAR_CHAR_STRING)=h0000000000000722971377324105728,cjr_name_(VAR_CHAR_STRING)=null,sfr(VAR_CHAR_STRING)=null,khly_dm(CHAR_STRING)=2,hy_dm(VAR_CHAR_STRING)=51,ms(VAR_CHAR_STRING)=null,lxr(VAR_CHAR_STRING)=张三,sjlx(CHAR_STRING)=0,create_time(DATETIME)=0000-00-00 00:00:00,cust_lx(INT8)=1,nsrlx_status_(INT8)=0,last_visit_time(DATETIME)=2025-08-13 14:23:25,last_visit_record(VAR_CHAR_STRING)=null,last_call_time_(DATETIME)=2025-08-13 14:23:25,last_gt_jg_(VAR_CHAR_STRING)=null,wh_status_(INT8)=0,yssj_ly(VAR_CHAR_STRING)=13,yssj_ly_sj(DATE)=null,yssj_cjr(VAR_CHAR_STRING)=null,yssj_cjr_name_(VAR_CHAR_STRING)=null,yssj_cjr2_(VAR_CHAR_STRING)=null,yssj_cjr_name2_(VAR_CHAR_STRING)=null,yssj_ly_sj2_(DATE)=null,zc_rq_(CHAR_STRING)=20180131,sign_type_(CHAR_STRING)=0,yssj_jgly(VAR_CHAR_STRING)=88888888888888888888888888888888,zcjg(VAR_CHAR_STRING)=null,belong_jgid_(VAR_CHAR_STRING)=88888888888888888888888888888888,khyxd_(CHAR_STRING)=null,is_zxh_(INT8)=null,has_yxth_(INT8)=1,has_yx_(INT8)=null,fwqx_z_(VAR_CHAR_STRING)=null,infra_bq_id(VAR_CHAR_STRING)=h0000000000000396934128592814080,h0000000000000396934128592814081,has_yhq_(CHAR_STRING)=null,infra_khbqz_id_(VAR_CHAR_STRING)=null,khbqz_size_(INT8)=null,marketing_stage_(INT8)=1,association_set_id_(CHAR_STRING)=null,clue_source_(CHAR_STRING)=0106,clue_channel_(CHAR_STRING)=null,organization_type_(CHAR_STRING)=0201,operation_status_(CHAR_STRING)=0402,communication_attitude_(CHAR_STRING)=null,listen_attitude_(CHAR_STRING)=null,cooperation_attitude_(CHAR_STRING)=null,appointment_attitude_(CHAR_STRING)=null,clue_validity_(INT8)=0,bookkeeping_condition_(CHAR_STRING)=null,prejudged_demand_(INT8)=0,has_contract_(CHAR_STRING)=null,pay_period_(CHAR_STRING)=null,expire_year_month_(INT24)=200000,business_income_(INT24)=null,voucher_amount_(INT24)=null,invoice_amount_(INT24)=null,declaration_status_(CHAR_STRING)=null,has_five_insurances_(CHAR_STRING)=null,has_housing_funds_(CHAR_STRING)=null,intent_level_(INT8)=2,highest_intent_level_(INT8)=2,social_credit_code_(VAR_CHAR_STRING)=91330101MA2B0N1MXP,operation_scope_(VAR_CHAR_STRING)=食品销售;技术开发、技术服务、技术咨询、成果转让:网络信息技术、计算机软硬件、电子商务技术、计算机系统集成;服务:承接计算机网络工程,利用信息网络经营游戏产品(含网络游戏虚拟货币发行),第二类增值电信业务中的信息服务业务(仅限互联网信息服务,不含新闻、出版、教育、医疗保健、药品和医疗器械、文化、广播电影电视节目等内容的信息服务、电子公告业务),机械设备租赁;批发、零售:计算机软硬件,通讯设备(除国家专控),电子产品,工艺美术品,日用百货,办公用品,机电设备,普通机械、图书、音像制品、初级食品农产品(除食品、药品)、服装、服饰、箱包、玩具(除国家专控)、母婴用品(除奶粉)、家纺用品、针织纺品、办公用品、电子元器件、数码产品、仪器仪表、体育用品及器材、化妆品(除分装)、卫生用品、第一类医疗器械、五金交电、建筑材料、装饰材料、包装材料、网络设备。(依法须经批准的项目,经相关部门批准后方可开展经营活动),kh_scene_wash_(INT16)=82,kh_scene_follow_(INT32)=2048,kh_scene_push_(INT8)=0,is_association_applied_(INT8)=0,update_date_(TIMESTAMP_IN_LONG)=1755072011.000000,is_qy_(CHAR_STRING)=0,qualification_(VAR_CHAR_STRING)=null,position_(VAR_CHAR_STRING)=null,dhhm_status_(VAR_CHAR_STRING)=null,mphone_status_(VAR_CHAR_STRING)=null,xxxq_demand_(VAR_CHAR_STRING)=null,intent_level_his_(CHAR_STRING)=2,2,2,2,2,intent_level_date_(DATETIME)=2020-11-17 19:36:57,tjdz_(VAR_CHAR_STRING)=null,yjcdrq_(DATE)=null,last_bj_date_(DATETIME)=null,last_bj_je_(NUMBER)=null,original_clue_source_(CHAR_STRING)=0106,source_update_date_(TIMESTAMP_IN_LONG)=null,work_wechat_status_(INT8)=0,kh_portrait_id_(VAR_CHAR_STRING)=null,encrypt_upgrade_status_(INT32)=0}] serialize to json fail.
983
at com.oceanbase.oms.connector.serializer.json.CanalJsonSerializer.serialize(CanalJsonSerializer.java:152)
984
at com.oceanbase.oms.connector.kafka.sink.KafkaSink$JsonStrSerializer.serializeRecord(KafkaSink.java:223)
985
at com.oceanbase.oms.connector.kafka.sink.KafkaSink$JsonStrSerializer.serializeRecord(KafkaSink.java:214)
986
at com.oceanbase.oms.connector.kafka.sink.KafkaSink.convertRecord(KafkaSink.java:177)
987
... 3 common frames omitted
988
Caused by: java.time.DateTimeException: Invalid value for MonthOfYear (valid values 1 - 12): 0
989
at java.time.temporal.ValueRange.checkValidValue(ValueRange.java:311)
990
at java.time.temporal.ChronoField.checkValidValue(ChronoField.java:703)
991
at java.time.LocalDate.of(LocalDate.java:267)
992
at com.oceanbase.oms.record.value.fieldvalue.timespec.GeneralDate.toLocaleDate(GeneralDate.java:109)
993
at com.oceanbase.oms.record.value.fieldvalue.timespec.GeneralDateTime.toZonedLocalDateTime(GeneralDateTime.java:100)
994
at com.oceanbase.oms.connector.serializer.json.CanalJsonSerializer.convertTime(CanalJsonSerializer.java:329)
995
at com.oceanbase.oms.connector.serializer.json.CanalJsonSerializer.getData(CanalJsonSerializer.java:300)
996
at com.oceanbase.oms.connector.serializer.json.CanalJsonSerializer.getData(CanalJsonSerializer.java:287)
997
at com.oceanbase.oms.connector.serializer.json.CanalJsonSerializer.serialize(CanalJsonSerializer.java:143)
998
... 6 common frames omitted
999
[2025-08-13 16:46:39.299] [WARN] [nioEventLoopGroup-2-1] [drcnet stopping...,drcnet recv buffer is set stopped, ignore data from netty]
1000
[2025-08-13 16:46:39.299] [WARN] [nioEventLoopGroup-2-1] [connection is stopped]

【复现路径】问题出现前后相关操作
【附件及日志】推荐使用OceanBase敏捷诊断工具obdiag收集诊断信息,详情参见链接(右键跳转查看):

【SOP系列 22 】——故障诊断第一步(自助诊断和诊断信息收集)

【备注】基于 LLM 和开源文档 RAG 的论坛小助手已开放测试,在发帖时输入 [@论坛小助手] 即可召唤小助手,欢迎试用!

3 个赞

目前对0000-00-00 00:00:00这种非法时间的处理存在问题,下个迭代我们优化一下。
这个应该是配置了dateConvertFormat吧,只能去掉这个配置来跳过这个问题

2 个赞

学习了! :+1:

原来如此,感谢。

学习