当前位置：网站首页>大佬们，求助一下，我用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 社区）
边栏推荐
- What types of Thawte wildcard SSL certificates provide
- 6.26CF模拟赛E：价格最大化题解
- 力扣刷题日记/day3/2022.6.25
- How is the entered query SQL statement executed?
- Wanghongru research group of Institute of genomics, Chinese Academy of Agricultural Sciences is cordially invited to join
- 2022-07-04：以下go语言代码输出什么？A：true；B：false；C：编译错误。 package main import 'fmt' func
- 2022养生展，健康展，北京大健康展，健康产业展11月举办
- Nature microbiology | viral genomes in six deep-sea sediments that can infect Archaea asgardii
- 字节跳动Dev Better技术沙龙成功举办，携手华泰分享Web研发效能提升经验
- 一种将Tree-LSTM的强化学习用于连接顺序选择的方法
猜你喜欢
神经网络物联网是什么意思通俗的解释
基于C语言的菜鸟驿站管理系统
.NET ORM框架HiSql实战-第二章-使用Hisql实现菜单管理(增删改查)
Nebula Importer 数据导入实践
Basic tutorial of scala -- 16 -- generics
![[go language question brushing chapter] go conclusion chapter | introduction to functions, structures, interfaces, and errors](/img/7a/16b481753d7d57f50dc8787eec8a1a.png)
[go language question brushing chapter] go conclusion chapter | introduction to functions, structures, interfaces, and errors
Scala基础教程--20--Akka
Nature Microbiology | 可感染阿斯加德古菌的六种深海沉积物中的病毒基因组
How is the entered query SQL statement executed?
2022年字节跳动日常实习面经(抖音)
随机推荐
基于unity的愤怒的小鸟设计
. Net ORM framework hisql practice - Chapter 2 - using hisql to realize menu management (add, delete, modify and check)
输入的查询SQL语句，是如何执行的？
Esp32-c3 introductory tutorial questions ⑫ - undefined reference to ROM_ temp_ to_ power, in function phy_ get_ romfunc_ addr
[uniapp] uniapp development app online Preview PDF file
Reptile elementary learning
力扣刷题日记/day5/2022.6.27
Scala basic tutorial -- 20 -- akka
6.26cf simulation race e: solution to the problem of price maximization
C语言打印练习
[2022 Jiangxi graduate mathematical modeling] curling movement idea analysis and code implementation
2022年字节跳动日常实习面经(抖音)
奥迪AUDI EDI INVOIC发票报文详解
输入的查询SQL语句，是如何执行的？
【Go语言刷题篇】Go完结篇|函数、结构体、接口、错误入门学习
力扣刷题日记/day2/2022.6.24
Cache é JSON uses JSON adapters
TorchDrug教程
Nebula Importer 数据导入实践
Perfect JS event delegation