0
点赞
收藏
分享

微信扫一扫

flutter 画转盘

7dcac6528821 2024-08-15 阅读 30

1、Flink on yarn模式下,flink cdc需要先启动yarn-session模式

 yarn-session.sh -n 10 -s 2

2、启动之后进行正常测试

CREATE TABLE test1(
id INT
PRIMARY KEY(id) NOT ENFORCED
) WITH (
'connector'='oracle-cdc',
'hostname'='127.0.01',
'port'='1521',
'username'='dwd',
'password'='dwd',
'database-name'='prod',
'table-name' ='test1','schema-name'='dw'
);
select * from test1 limit 10;

3、oracle驱动缺失, on yarn缺失的jar需要拷贝到#FLINK_HOME/lib/

scp ojdbc8-21.5.0.0.jar hdfs@hadoop09:/BigData/run/flink/lib/

举报

相关推荐

0 条评论