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 cdc启动时候报错线程不够 可以通过什么方式解决吗

flink cdc启动时候报错线程不够 可以通过什么方式解决吗

flink,50000条数据写入mysql太慢怎么办啊,除了多线程还有其他方法吗,已经是批量写入了

问一个关于flink和hadoop版本的问题。目前我们生产环境是hadoop3.0+的版本,现在官网上flink1.9+没有直接打包好的捆绑的hadoop3.0+的版本。 但是我自己下载flink1.9.1版本,然后下载了 可选组件里的 Pre-bundled Hadoop 2.8.3 (asc, ...

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