当前位置:网站首页>Guys, for help, I use MySQL CDC 2.2.1 (Flink 1.14.5) to write Kafka and set
Guys, for help, I use MySQL CDC 2.2.1 (Flink 1.14.5) to write Kafka and set
2022-07-04 19:19:00 【Alibaba cloud Q & A】
bosses , Ask for help , I use mysql cdc 2.2.1(flink 1.14.5) write in kafka, Set up 8 Parallel degrees , The production environment is running 8 individual subtask, But there's only one subtask Sending and receiving data , Please consult , What's going on here ?
Take the answer 1:
read binlog Stage , Only one parallelism is being read ( This answer is collated from Flink CDC Community )
边栏推荐
- Process of manually encrypt the mass-producing firmware and programming ESP devices
- Scala基础教程--20--Akka
- 整理混乱的头文件,我用include what you use
- IBM WebSphere MQ检索邮件
- 英特尔集成光电研究最新进展推动共封装光学和光互连技术进步
- Digital "new" operation and maintenance of energy industry
- Go microservice (II) - detailed introduction to protobuf
- 大佬们,求助一下,我用mysql cdc 2.2.1(flink 1.14.5)写入kafka,设置
- TorchDrug教程
- Scala basic tutorial -- 17 -- Collection
猜你喜欢
英特尔集成光电研究最新进展推动共封装光学和光互连技术进步
2022CoCa: Contrastive Captioners are Image-Text Fountion Models
Scala basic tutorial -- 19 -- actor
2022 ByteDance daily practice experience (Tiktok)
MXNet对GoogLeNet的实现(并行连结网络)
自由小兵儿
ByteDance dev better technology salon was successfully held, and we joined hands with Huatai to share our experience in improving the efficiency of web research and development
LeetCode第300场周赛(20220703)
[2022 Jiangxi graduate mathematical modeling] curling movement idea analysis and code implementation
每日一题(2022-07-02)——最低加油次数
随机推荐
6.26CF模拟赛B:数组缩减题解
C#实现定义一套中间SQL可以跨库执行的SQL语句(案例详解)
Learning path PHP -- phpstudy "hosts file does not exist or is blocked from opening" when creating the project
Unity编辑器扩展C#遍历文件夹以及子目录下的所有图片
神经网络物联网是什么意思通俗的解释
正则替换【JS,正则表达式】
Rookie post station management system based on C language
从实时应用角度谈通信总线仲裁机制和网络流控
Scala basic tutorial -- 12 -- Reading and writing data
ByteDance dev better technology salon was successfully held, and we joined hands with Huatai to share our experience in improving the efficiency of web research and development
Deleting nodes in binary search tree
ESP32-C3入门教程 问题篇⑫——undefined reference to rom_temp_to_power, in function phy_get_romfunc_addr
Scala基础教程--19--Actor
From automation to digital twins, what can Tupo do?
小发猫物联网平台搭建与应用模型
Halcon模板匹配
Digital "new" operation and maintenance of energy industry
File processing examples of fopen, FREAD, fwrite, fseek
Other InterSystems%net tools
Scala基础教程--20--Akka