Questions Tags Users Badges

Flink CdcTools 使用Logminer方式 oracle 单库模式下如果某张表列名长度超30字符将无法捕获

Asked Sep 19, 2025 Modified Sep 19, 2025

Viewed 42

ingestion

completeTable 'test_tab' won't be captured by Oracle LogMiner because column 'TEST_XXXXXXXX_XXXXXX_EFFECT_TIME' exceeds 30 characters.

doris版本 apache-doris-2.1.10
flink-doris-connector-1.20-24.0.1.jar
flink-sql-connector-oracle-cdc-3.4.0.jar

edited Sep 19, 2025

wayne1

asked Sep 19, 2025

1 Answers

debezium本身限制的 https://github.com/debezium/debezium/blob/1.9/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java#L747-L763

可以修改debeizum的这个类，并且重新打包FlinkCDC

edited Sep 19, 2025

JNSimba336

answered Sep 19, 2025

Related Questions

Spark Doris Connector 从hive导入doris double类型丢精度怎么解决？

4.0.3 mysql 通过CREATE JOB 同步数据之后中文变成了?

ROUTINE LOAD导入kafka数据，当kafka是cdc数据，JSON格式，带删除标识的:op:d

大量数据通过streamload导入报错

能使用ROUTINE LOAD将kafka数据批量同步到doris中吗

4.0.4 stream load 报错： can not cast from origin type bitmap to target type=varchar(65533)