Yes, thank you very much for paying attention to my question. I will describe in detail the problem I encountered.
I am currently using flink-cdc(v3.3) to synchronize oracle's data from the library to kafka. The debezium version used at the bottom layer of flink-cdc is v1.9.8.Final. The debezium parameter I passed in when constructing OraclSource is:
{
"decimal.handling.mode" = "string"
"include-comment-changes" = "true"
"include-schema-changes" = "true"
"log.mining.strategy" = "online_catalog"
"lob.enabled" = "true"
"message.key.columns" = "ORCL.TB:ID"
}My table creation statement is:
create table ORCL.TB
(
INVENTORY_DETAID NUMBER(30) not null,
INVENTORYDETA_REL_ID NUMBER(30) not null,
ID NUMBER(14)
)It is worth noting that there is no clob type field in my table. I have already placed the error message of the program after startup in the attachment. I know that since flik-cdc was introduced in the synchronization, the error might not have been caused by debezium, but I can't find a solution to the problem now and can only look for answers in both communities. In the absence of an upgrade to the debezium version, how can I solve this problem? Do I need to merge some code from the higher version or add some configuration to solve it? Thank you again for paying attention to my question !!!