开发者社区 > 大数据与机器学习 > 大数据开发治理DataWorks > 正文

大神们，flinkcdc oracle 表的数据量大时就无法全量同步，这个如何解决？

大神们，flinkcdc oracle 表的数据量大时就无法全量同步，这个如何解决？ --应收单分录 CREATE TABLE T_AR_OTHERBILLENTRY ( FID STRING, FPARENTID STRING, FRECIEVEPAYAMOUNTLOCAL DECIMAL(20, 8), FLOCALBADAMOUT DECIMAL(20, 8) ) WITH ( 'connector' = 'oracle-cdc', 'hostname' = '192.168', 'port' = '1521', 'username' = '', 'password' = 'y', 'database-name' = '', 'schema-name' = '',
'table-name' = 'T_AR_OTHERBILLENTRY', 'debezium.database.tablename.case.insensitive' = 'false', 'debezium.log.mining.strategy' = 'online_catalog', 'debezium.log.mining.continuous.mine' = 'true', 'scan.startup.mode' = 'initial' );

展开

收起

滴滴滴~ 2023-03-21 14:23:37 243 0

1 条回答

写回答

取消提交回答

圆葱猪肉包

EXECUTE CDCSOURCE cdc_oracle WITH ( 'connector' = 'oracle-cdc', 'hostname' = '127.0.0.1', 'port' = '1521', 'username'='root', 'password'='123456', 'database-name'='ORCL', 'checkpoint' = '3000', 'scan.startup.mode' = 'initial', 'parallelism' = '1', 'table-name' = 'TEST..*', 'connector' = 'jdbc', 'url' = 'jdbc:oracle:thin:@127.0.0.1:1521:orcl', 'username' = 'root', 'password' = '123456', 'table-name' = 'TEST2.${tableName}' ) 此答案整理自钉群“Flink CDC 社区”

2023-03-21 16:40:22

赞同展开评论打赏