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/
本站资源均来自互联网,仅供研究学习,禁止违法使用和商用,产生法律纠纷本站概不负责!如果侵犯了您的权益请与我们联系!
转载请注明出处: 免费源码网-免费的源码资源网站 » Flink cdc正确打开方式(flink on yarn)
发表评论 取消回复