flink里面使用pemja执行python脚本的话也是单线程方式么?如果不是,请问是如果使用pem

flink里面使用pemja执行python脚本的话也是单线程方式么?如果不是,请问是如果使用pemja的呢?

Flink CDC 中mysql cdc的schema读取阶段是不是单线程串行的?

Flink CDC 中mysql cdc的schema读取阶段是不是单线程串行的?

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

Flink CDC多线程限制么?这日志一直再跑,但是表早就更新了

Flink CDC多线程限制么?这日志一直再跑,但是表早就更新了 好像内存快满了

Flink CDC这个线程都开到2000多了,这个是为什么?

Flink CDC这个线程都开到2000多了,这个是为什么?

Flink cdc消费端是不是单线程消费?不然没法控制执行顺序把?

Flink cdc消费端是不是单线程消费?不然没法控制执行顺序把?

Flink CDC中oracle的logminer是单线程处理 日志的,所以oracle数据库事务?

Flink CDC中oracle的logminer是单线程处理 日志的,所以oracle数据库事务变化快,debezuim里面视图查到的scn好像会追不上新的scn,就算调大了batchsize 也没用啊,有什么好的解决办法吗

大佬们,问个小白问题,flink cdc不是只能单线程采集数据,然后把采集的数据放到kafka,ka

大佬们,问个小白问题,flink cdc不是只能单线程采集数据,然后把采集的数据放到kafka,kafka,5个分区,你们说并行度设置多少合适?用yarn per job提交, -Dparallelism.default,设置成多少?跟kafka分区数一致,说设置成5,还是跟源头一样,直接设置成1

在flink下,如果用 keyby进行分区之后,怎样才能 keyby之后只让一个线程进?

如果用 keyby进行分区之后 每一个区里的数据也会并行处理,怎样才能 keyby之后只让一个线程进行处理呀?比如这种 

实时计算 Flink版这么写有没有线程安全问题啊?

实时计算 Flink版这么写有没有线程安全问题啊?

Flink CDC 请教一下,oceanbase cdc 在抽数的时候,因为目前只支持单线程,所以速

Flink CDC 请教一下,oceanbase cdc 在抽数的时候,因为目前只支持单线程,所以速度比较慢,57万条数据,跑了将近9分钟才跑完,还有什么办法可以提高抽数效率?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载