当前位置:网站首页>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 )
边栏推荐
猜你喜欢

Halcon template matching

How is the entered query SQL statement executed?

An example of multi module collaboration based on NCF

A method of using tree LSTM reinforcement learning for connection sequence selection

Scala basic tutorial -- 20 -- akka

Angry bird design based on unity

Li Kou brush question diary /day4/6.26

Wanghongru research group of Institute of genomics, Chinese Academy of Agricultural Sciences is cordially invited to join

学习路之PHP--phpstudy创建项目时“hosts文件不存在或被阻止打开”

Rookie post station management system based on C language
随机推荐
Scala basic tutorial -- 17 -- Collection
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
工厂从自动化到数字孪生,图扑能干什么?
Using FTP
Nature microbiology | viral genomes in six deep-sea sediments that can infect Archaea asgardii
IBM WebSphere MQ检索邮件
国元期货是正规平台吗?在国元期货开户安全吗?
Interpretation of SIGMOD '22 hiengine paper
从实时应用角度谈通信总线仲裁机制和网络流控
vbs或vbe如何修改图标
[go ~ 0 to 1] read, write and create files on the sixth day
A method of using tree LSTM reinforcement learning for connection sequence selection
利用策略模式优化if代码【策略模式】
BI技巧丨权限轴
2022 ByteDance daily practice experience (Tiktok)
DeFi生态NFT流动性挖矿系统开发搭建
Lex and yacc based lexical analyzer + parser
6.26CF模拟赛B:数组缩减题解
Uni app and uviewui realize the imitation of Xiaomi mall app (with source code)
Scala基础教程--19--Actor