当前位置：网站首页>大佬们，求助一下，我用mysql cdc 2.2.1（flink 1.14.5）写入kafka，设置
大佬们，求助一下，我用mysql cdc 2.2.1（flink 1.14.5）写入kafka，设置
2022-07-04 17:36:00 【阿里云问答】
大佬们，求助一下，我用mysql cdc 2.2.1（flink 1.14.5）写入kafka，设置8个并行度，生产环境跑着8个subtask，但只有一个subtask在收发数据，请教一下，这个是怎么回事儿呢？
采纳答案1：
读binlog阶段,只有一个并行度在读取（此答案整理自Flink CDC 社区）
边栏推荐
- 【云端心声 建议征集】云商店焕新升级：提有效建议，赢海量码豆、华为AI音箱2！
- 6.26CF模拟赛E：价格最大化题解
- 【2022年江西省研究生数学建模】水汽过饱和的核化除霾 思路分析及代码实现
- 力扣刷题日记/day7/2022.6.29
- 千万不要只学 Oracle、MySQL！
- Is the securities account opened by qiniu safe?
- Improve the accuracy of 3D reconstruction of complex scenes | segmentation of UAV Remote Sensing Images Based on paddleseg
- 国元期货是正规平台吗？在国元期货开户安全吗？
- 启牛开的证券账户安全吗？
- Installation and use of VMware Tools and open VM tools: solve the problems of incomplete screen and unable to transfer files of virtual machines
猜你喜欢
Learning path PHP -- phpstudy "hosts file does not exist or is blocked from opening" when creating the project
Scala基础教程--13--函数进阶
Angry bird design based on unity
Neglected problem: test environment configuration management
Nature Microbiology | 可感染阿斯加德古菌的六种深海沉积物中的病毒基因组
基于unity的愤怒的小鸟设计
2022年字节跳动日常实习面经(抖音)
TorchDrug教程
【uniapp】uniapp开发app在线预览pdf文件
Scala basic tutorial -- 20 -- akka
随机推荐
Microservice architecture debate between radical technologists vs Project conservatives
Torchdrug tutorial
Wireshark抓包TLS协议栏显示版本不一致问题
神经网络物联网应用技术学什么
正则替换【JS，正则表达式】
Nebula Importer 数据导入实践
Scala basic tutorial -- 18 -- set (2)
ThreadLocal原理与使用
[211] go handles the detailed documents of Excel library
Rookie post station management system based on C language
Scala基础教程--12--读写数据
基于NCF的多模块协同实例
What if the self incrementing ID of online MySQL is exhausted?
Li Kou brush question diary /day6/6.28
2022 ByteDance daily practice experience (Tiktok)
repeat_P1002 [NOIP2002 普及组] 过河卒_dp
A method of using tree LSTM reinforcement learning for connection sequence selection
[uniapp] uniapp development app online Preview PDF file
【2022年江西省研究生数学建模】水汽过饱和的核化除霾 思路分析及代码实现
力扣刷题日记/day1/2022.6.23