各位老师，Flink CDC中我两个job里分别是不同的mysqlcdc源，两个源的表结构是一样的？
各位老师，Flink CDC中我两个job里分别是不同的mysqlcdc源，两个源的表结构是一样的，往同一个paimon表插入的时候，job2起不来，这是什么原因呢？
job2往paimon表里sink的时候红了
日志里 报了一个访问拒绝的错，两个不同的mysql源表，利用cdc，不能往同一个sink表里插数据吗？
展开
收起
1
条回答
写回答
写回答
-
你的连接信息是192.168.191.210吗？连接配置贴出来，student_score_paiomn_1的连接配置呢？试试单独用CDC读取student_score_table的数据，如果没问题就是依赖student_score_paiomn_1的问题，此回答整理自钉群“Flink CDC 社区”
2023-07-19 15:06:26赞同 展开评论 打赏
相关产品：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
热门讨论
热门文章
FFA 2024 大会门票免费送！AI时代下大数据技术未来路在何方？
1097
P人出游，你是否需要一个懂你更懂规划的AI导游呢？来搭建专属文旅问答机器人吧
1726
兄弟们啊，同步中DI、RI到底什么意思，是什么的缩写？
355
数据来源：com.alibaba.fastjson.JSONException: syntax er
5529
虚拟机占用内存特别大，90多个G,网上各种方法都试过了，怎么解决这个问题
1368
Slot request bulk is not fulfillable，20以上job同时部署失败
699
Caused by: org.apache.kafka.common.errors.TimeoutE
3230
dataworks里面的stg层、ods层、dwd层、dws层、是怎么分层的呢？
2596
FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
3514
大佬，Caused by: java.lang.ClassNotFoundException: or
441
展开全部
数加：从数据工程师到CDO的七次升职路
8653
Flink: 实时规则引擎助力新零售发展
10006
基于实时计算（Flink）与高斯模型构建实时异常检测系统
7979
阿里关涛谈大规模计算—从数字化阿里到数字化城市的进化
5020
DataWorks智能数据建模全面公测开始啦！
4261
DataWorks售前咨询
8515
如何在Windows和Mac上免费将蓝光转换为MKV？
452
什么是HTTP代理？HTTP代理的作用？HTTP代理怎么设置？
7408
Java“找不到符号” 错误怎么查找解决
1131
Ubuntu 报错：System has not been booted with systemd as init system (PID 1). Can‘t operate.
1783
展开全部
相关课程
更多
相关电子书
更多
